kafkaReceiveTest.py 838 B

123456789101112131415161718
  1. from kafka import KafkaConsumer
  2. # consumer = KafkaConsumer('eip_rec_behave',
  3. # group_id='test1', # 一个组消费一次
  4. # auto_offset_reset='earliest', # 从最新数据读取,earliest,latest
  5. # enable_auto_commit=False, # 关闭自动提醒
  6. # bootstrap_servers=['eip-kafka-2.qa.mlamp.cn']
  7. # )
  8. # for msg in consumer:
  9. # print(msg.value)
  10. # consumer.commit()
  11. consumer = KafkaConsumer('eip_rec_behave',
  12. group_id='test1', # 一个组消费一次
  13. auto_offset_reset='latest', # 从最新数据读取,earliest,latest
  14. bootstrap_servers=['eip-kafka-2.qa.mlamp.cn']
  15. )
  16. for msg in consumer:
  17. print(msg.value)