Hello.

I am trying to create consumer using kafka_python-0.9.5.

I expect that several instances of the script

==
consumer = KafkaConsumer('some-topic',
                         auto_offset_reset='largest',
                         metadata_broker_list=['localhost:9092'],
                         group_id='vasya_group',
                         auto_commit_enable=True)
consumer.set_topic_partitions('some-topic')
while True:
    msg=consumer.next()
    print(msg)
==
would receive different messages, while in reality every instance receives all 
messages.

What can be done to achieve 
"Consumers label themselves with a consumer group name, and each message 
published to a topic is delivered to one consumer instance within each 
subscribing consumer group" as advertised in Kafka Documentation?

I am 100% that messages are distributed among several partitions (namely 10).

Thanks.

-- 
Best regards
Ilja Golshtein

Reply via email to