code: def test_kafka_offset(kafka_client, topic, commit_offset):
      offsets = [ck.TopicPartition(topic, 0, commit_offset)]
      kafka_client.commit(offsets=offsets)
  
      # Get the offsets that were just committed to Kafka
      retrieved_offsets = kafka_client.committed(offsets)
  
      for off in retrieved_offsets:
          assert_eq(off.topic, offsets[0].topic)
          assert_eq(off.partition, offsets[0].partition)
          assert_eq(off.offset, offsets[0].offset)
  
label_desc: Use image node_id 1 for calling a global function with example usage: test_kafka_offset(kafka_client, topic, commit_offset) without return types