change neo4j consumers consumer group. Also add both consumers to docker-compose.yml

docker/docker-compose.yml

@@ -27,12 +27,12 @@ services:
     environment:
        - NEO4J_AUTH=none
 
-#  consumer:
-#    build:
-#      context: ..
-#      dockerfile: docker/kafka/consumer/Dockerfile
-#    links:
-#      - kafka
+  stdout-consumer:
+    build:
+      context: ..
+      dockerfile: docker/kafka/consumer/Dockerfile
+    links:
+      - kafka
 
 #  producer:
 #    build:

docker/kafka/neo4j-consumer/consumer.py

@@ -18,6 +18,7 @@ def connect_kafka():
             consumer = KafkaConsumer('swift',
                                      bootstrap_servers='kafka:9092',
                                      client_id='swift-kafka-consumer',
+                                     group_id='kafka-python-neo4j-consumer',
                                      key_deserializer=lambda k: k.decode(
                                          'utf-8'),
                                      value_deserializer=lambda m: json.loads(