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)