diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 7b8b0656ae192affc8cedd38c1472a82c329f31c..8da12ef5c0f1c8c1cb489618f3e70f07bd89dabe 100644
--- a/docker/docker-compose.yml
+++ b/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:
diff --git a/docker/kafka/neo4j-consumer/consumer.py b/docker/kafka/neo4j-consumer/consumer.py
index e40e1835d22891bef6c94fe122166bb022009d4f..8e18c802951d6051ee553876bdb3d041480d2549 100644
--- a/docker/kafka/neo4j-consumer/consumer.py
+++ b/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(