多的消費者在同一消費羣

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。