Ottomata has submitted this change and it was merged. (
https://gerrit.wikimedia.org/r/401750 )
Change subject: Have to subscribe if using multiple kafka topics.
......................................................................
Have to subscribe if using multiple kafka topics.
Bug: T179093
Change-Id: I33be897a9170836de6d55fa3cb7a163dc988fce9
---
M statsv.py
1 file changed, 1 insertion(+), 1 deletion(-)
Approvals:
Ottomata: Verified; Looks good to me, approved
diff --git a/statsv.py b/statsv.py
index 627d79b..9d0b591 100644
--- a/statsv.py
+++ b/statsv.py
@@ -204,7 +204,6 @@
# Create our Kafka Consumer instance.
consumer = KafkaConsumer(
- kafka_topics,
bootstrap_servers=kafka_bootstrap_servers,
group_id=kafka_consumer_group,
auto_offset_reset='latest',
@@ -213,6 +212,7 @@
enable_auto_commit=False,
consumer_timeout_ms=kafka_consumer_timeout_seconds * 1000
)
+consumer.subscribe(kafka_topics)
watchdog = Watchdog()
--
To view, visit https://gerrit.wikimedia.org/r/401750
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: merged
Gerrit-Change-Id: I33be897a9170836de6d55fa3cb7a163dc988fce9
Gerrit-PatchSet: 1
Gerrit-Project: analytics/statsv
Gerrit-Branch: master
Gerrit-Owner: Ottomata <ao...@wikimedia.org>
Gerrit-Reviewer: Ottomata <ao...@wikimedia.org>
_______________________________________________
MediaWiki-commits mailing list
MediaWiki-commits@lists.wikimedia.org
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
