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

Popular posts from this blog

Capture and play voice with Asterisk ARI -

c++ - Can not find the "fiostream.h" file -

visual studio - Installing Packages through Nuget - "Central Directory corrupt" -