同一消费组中的多个消费者

Question

我在同一个组（我的组）中有 1 个生产者和 1 个消费者。

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

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

Answer 1

SimpleConsumer 不支持消费组，你应该使用 KafkaConsumer 来代替。