同一用户组中的多个用户

brc7rcf0  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(392)

我在同一组(我的组)中有一个生产者和一个消费者。

  1. # To send messages asynchronously
  2. producer = SimpleProducer(kafka, async=True)
  3. producer.send_messages("my-topic", "async message")
  4. # To consume messages, consumer1
  5. consumer1 = SimpleConsumer(kafka, "my-group", "my-topic")
  6. for message in consumer1:
  7. print(message)
c3frrgcw

c3frrgcw1#

simpleconsumer不支持消费群体,您应该使用kafkaconsumer。

相关问题