Потребители Kafka Python перечитывают всю часть

Question

Я создал разделы kafka, но когда я запускаю несколько потребителей, все потребители читают одно и то же сообщение всех разделов.Вот мой пример кода.

from kafka import KafkaClient, SimpleConsumer 
from kafka import KafkaConsumer 
from sys 
import argv 
import time 
consumer = KafkaConsumer("abc", group_id='my-group', bootstrap_servers=['my-server']) 
for message in consumer: 
       #time.sleep(6) 
       print "PARTITION "+str(message[1])+" OFFSET: "+str(message[2])+"\t MSG: "+str(message[4])
       consumer.commit()