Hi,

I created a few consumers that belong to the same group_id, but I noticed that 
each consumer get all messages instead of only some of the messages.

As for the topic, I did create the topic with a few partitions.

Anyone else had the same problem? Is there any configuration parameter I need 
to set in order for consumer groups to work?

Below the sample of the python code:
consumer = KafkaConsumer(topic, group_id, bootstrap_servers=["%s:%d" % 
(kafka_host, kafka_port)])


Thanks!
Joyce



Reply via email to