从文档..[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)
“我的小组”是从哪里来的?如何设置“我的组”?
最佳答案
根据SimpleConsumer
的docstring,group
是“此使用者的名称,用于偏移量存储,并且必须是唯一的”。
所以这只是你给消费者的一个独一无二的名字。