python - Multiple consumers in same consumer group -
i have 1 producer , 1 consumers in same group (my-group).
# send messages asynchronously producer = simpleproducer(kafka, async=true) producer.send_messages("my-topic", "async message") # consume messages, consumer1 consumer1 = simpleconsumer(kafka, "my-group", "my-topic") message in consumer1: print(message)
simpleconsumer doesn't support consumer groups, should use kafkaconsumer instead.
Comments
Post a Comment