Ottomata has submitted this change and it was merged. (
https://gerrit.wikimedia.org/r/329640 )
Change subject: Properly use topic from kafkaMessage in meta
......................................................................
Properly use topic from kafkaMessage in meta
Change-Id: Ibe4ed3a6bd46c7310a6ddc5a74f7cbe1e66935b9
---
M lib/eventstreams-util.js
1 file changed, 1 insertion(+), 1 deletion(-)
Approvals:
Ottomata: Verified; Looks good to me, approved
diff --git a/lib/eventstreams-util.js b/lib/eventstreams-util.js
index 2c5eb7c..828e472 100644
--- a/lib/eventstreams-util.js
+++ b/lib/eventstreams-util.js
@@ -45,7 +45,7 @@
if (!kafkaMessage.message.meta) {
kafkaMessage.message.meta = {};
}
- kafkaMessage.message.meta.topic = kafkaMessage.topic_name;
+ kafkaMessage.message.meta.topic = kafkaMessage.topic;
kafkaMessage.message.meta.partition = kafkaMessage.partition;
kafkaMessage.message.meta.offset = kafkaMessage.offset;
if (kafkaMessage.key) {
--
To view, visit https://gerrit.wikimedia.org/r/329640
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: merged
Gerrit-Change-Id: Ibe4ed3a6bd46c7310a6ddc5a74f7cbe1e66935b9
Gerrit-PatchSet: 1
Gerrit-Project: mediawiki/services/eventstreams
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
