kafkaReceiveTest.py 556 B

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