从文档..[1]:https://github.com/mumrah/kafka-python

# To send messages asynchronously
producer = SimpleProducer(kafka, async=True)
producer.send_messages("my-topic", "async message")

# To consume messages
consumer = SimpleConsumer(kafka, "my-group", "my-topic")
for message in consumer:
    print(message)

“我的小组”是从哪里来的?如何设置“我的组”?

最佳答案

根据SimpleConsumerdocstringgroup是“此使用者的名称,用于偏移量存储,并且必须是唯一的”。
所以这只是你给消费者的一个独一无二的名字。

10-07 19:48
查看更多