consume

Author: N. Mert Aydin (he.him)

docker-compose.yml

@@ -50,7 +50,7 @@ services:
       - PYTHONUNBUFFERED=1
     volumes:
       - ./py:/home/
-    command: bash -c "pip install kafka-python && python /home/parse-engine.py"
+    command: bash -c "pip install kafka-python && python /home/consume.py"
     depends_on:
       - kafka
     restart: always

py/parse-engine.py renamed to py/consume.py

@@ -1,12 +1,10 @@
 from kafka import KafkaConsumer
-import json
 
 try:
-    print('Welcome to parse engine')
+    print('Hello. I am about to consume maxwell messages...')
     consumer = KafkaConsumer('maxwell', bootstrap_servers='kafka:9092')
     for message in consumer:
         print(message)
 except Exception as e:
     print(e)
-    # Logs the error appropriately. 
     pass