python - Kafka 和 python - 我不知道如何消费

Question

来自文档..[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)

“我的组”从何而来？如何设置“我的组”？

Answer 1

根据docstring SimpleConsumer，group是“这个消费者的名字，用于偏移量存储，必须是唯一的”。

所以这只是您给消费者的唯一名称。