Skip to content

Instantly share code, notes, and snippets.

@wangxiangyu

wangxiangyu/gist:2fb73be1266fd74cd9e5

Created December 3, 2014 07:11
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save wangxiangyu/2fb73be1266fd74cd9e5 to your computer and use it in GitHub Desktop.
Save wangxiangyu/2fb73be1266fd74cd9e5 to your computer and use it in GitHub Desktop.
Download ZIP
Two consumers belong to the same group get the same message
Raw
gistfile1.txt
from kafka import KafkaClient,SimpleConsumer
broker_list='172.16.29.216:9093,172.16.29.216:9092'
kafka = KafkaClient(broker_list)
consumer=SimpleConsumer(kafka,'my-group','test')
for message in consumer:
print message
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment