From 1e5d2df512c1b470814d390d41ae6ccf0dffd213 Mon Sep 17 00:00:00 2001
From: bne86 <benedikt@zam476.zam.kfa-juelich.de>
Date: Thu, 19 Jan 2017 14:36:13 +0100
Subject: [PATCH] change neo4j consumers consumer group. Also add both
consumers to docker-compose.yml
---
docker/docker-compose.yml | 12 ++++++------
docker/kafka/neo4j-consumer/consumer.py | 1 +
2 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 7b8b065..8da12ef 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 e40e183..8e18c80 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(
--
GitLab