Skip to content

Instantly share code, notes, and snippets.

@ashish-mj

ashish-mj/consumer.py

Created January 23, 2022 15:44
Show Gist options
  • Save ashish-mj/35fbbd389d8affe4d41261e308413817 to your computer and use it in GitHub Desktop.
Save ashish-mj/35fbbd389d8affe4d41261e308413817 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
consumer.py
from kafka import KafkaConsumer
bootstrap_servers = ['localhost:9092']
topicName = 'Media'
consumer = KafkaConsumer (topicName,bootstrap_servers = bootstrap_servers)
for message in consumer:
print(message)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment