多的消费者在同一消费群

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。