initial commit

1 files changed, 18 insertions, 0 deletions

diff --git a/consumer.py b/consumer.py
new file mode 100644
index 0000000..955aba2
--- /dev/null
+++ b/consumer.py
@@ -0,0 +1,18 @@
+from kafka import KafkaConsumer
+from json import loads
+from time import sleep
+
+consumer = KafkaConsumer(
+    'topic_test',
+    bootstrap_servers=['kafka:9092'],
+    auto_offset_reset='earliest',
+    enable_auto_commit=True,
+    group_id='my-group-id',
+    value_deserializer=lambda x: loads(x.decode('utf-8'))
+)
+
+for event in consumer:
+    event_data = event.value
+    # Do whatever you want
+    print(event_data)
+    sleep(2)