python-base--/tmp/kafka/kafkaReceiveTest.py

from kafka import KafkaConsumer

# tag_sink_topic\tag_atom_topic
consumer = KafkaConsumer('tag_atom_topic',
                         group_id='test115',  # 一个组消费一次
                         auto_offset_reset='latest',  # 从最新数据读取,earliest,latest
                         # bootstrap_servers=['kafka-0.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092', 'kafka-1.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092', 'kafka-2.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092']
                         bootstrap_servers=['kafka-0.kafka-headless.aimptest.svc.k5.bigtree.zone:9092', 'kafka-1.kafka-headless.aimptest.svc.k5.bigtree.zone:9092', 'kafka-2.kafka-headless.aimptest.svc.k5.bigtree.zone:9092']
                         )
for msg in consumer:
    print(msg.value)