Несколько потребителей в той же группе потребителей

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.