kafkaReceiveTest11.py 406 B

123456789
  1. from kafka import KafkaConsumer
  2. # tag_sink_topic\tag_atom_topic
  3. consumer = KafkaConsumer('tag_atom_topic',
  4. group_id='test11', # 一个组消费一次
  5. auto_offset_reset='latest', # 从最新数据读取,earliest,latest
  6. bootstrap_servers=['192.168.36.199:9092']
  7. )
  8. for msg in consumer:
  9. print(msg.value)