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

from kafka import KafkaConsumer

consumer = KafkaConsumer('eip_rec_behave',
                         group_id='test1',  # 一个组消费一次
                         auto_offset_reset='earliest',  # 从最新数据读取,earliest,latest
                         enable_auto_commit=False,  # 关闭自动提醒
                         bootstrap_servers=['eip-kafka-2.qa.mlamp.cn']
                         )
for msg in consumer:
    print(msg.value)
    consumer.commit()

# consumer = KafkaConsumer('eip_rec_behave',
#                          group_id='test1',  # 一个组消费一次
#                          auto_offset_reset='latest',  # 从最新数据读取,earliest,latest
#                          bootstrap_servers=['eip-kafka-2.qa.mlamp.cn']
#                          )
# for msg in consumer:
#     print(msg.value)