从文件中..[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)“我的团队”是从哪里来的？如何设置“我的团队”？
3条答案
按热度按时间dfty9e191#
根据
SimpleConsumer,group是“此使用者的名称，用于偏移存储，并且必须是唯一的”。所以这只是你给消费者的一个独特的名字。
uplii1fm2#
Kafka使用分组来协调多个消费者阅读同一主题。如果多个消费者使用相同的组名，它会告诉kafka他们想要共享消费者负载，并且每条消息将只传递给其中一个组成员。
如果你还不知道你想要小组，你可能不知道。只需确保名称是唯一的，这样Kafka就可以向您的消费者发送关于该主题的所有可用消息。
vfh0ocws3#
如前所述，每条消息只应向每个消费群体传递一次。有关详细信息，请检查http://kafka.apache.org/documentation.html#introduction.
在kafka python的最后一个版本（编写本文时为0.9.3）之前，使用simpleconsumer的用户组不能正常工作。