Skip to content

Instantly share code, notes, and snippets.

@dvainrub

dvainrub/kafka-consumer-basic.py

Last active June 6, 2019 10:54
Show Gist options
  • Save dvainrub/4000b214c10ee3fe91ad894743b15461 to your computer and use it in GitHub Desktop.
Save dvainrub/4000b214c10ee3fe91ad894743b15461 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka-consumer-basic.py
from kafka import KafkaConsumer
from json import loads
consumer = KafkaConsumer(
'test',
auto_offset_reset='earliest',
enable_auto_commit=True,
group_id='my-group-1',
value_deserializer=lambda m: loads(m.decode('utf-8')),
bootstrap_servers=['172.17.0.1:32783','172.17.0.1:32782','172.17.0.1:32781'])
for m in consumer:
print(m.value)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment