kafkaReceiveTest.py 397 B

1234567891011
  1. from kafka import KafkaConsumer, TopicPartition
  2. consumer = KafkaConsumer('eip_rec_behave',
  3. group_id='test11', # 一个组消费一次
  4. auto_offset_reset='latest', # 从最新数据读取,earliest,latest
  5. bootstrap_servers=['eip-kafka-2.qa.mlamp.cn']
  6. )
  7. for msg in consumer:
  8. print(msg.value)