同一消费者组中的多个消费者
Multiple consumers in same consumer group
我在同一组(我的组)中有 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)
SimpleConsumer 不支持消费者组,您应该改用 KafkaConsumer。
我在同一组(我的组)中有 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)
SimpleConsumer 不支持消费者组,您应该改用 KafkaConsumer。