[MediaWiki-commits] [Gerrit] mediawiki...eventstreams[master]: Properly use topic from kafkaMessage in meta
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
Gerrit-Reviewer: Ottomata
___
MediaWiki-commits mailing list
MediaWiki-commits@lists.wikimedia.org
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
[MediaWiki-commits] [Gerrit] mediawiki...eventstreams[master]: Properly use topic from kafkaMessage in meta
Ottomata has uploaded a new change for review. (
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(-)
git pull ssh://gerrit.wikimedia.org:29418/mediawiki/services/eventstreams
refs/changes/40/329640/1
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: newchange
Gerrit-Change-Id: Ibe4ed3a6bd46c7310a6ddc5a74f7cbe1e66935b9
Gerrit-PatchSet: 1
Gerrit-Project: mediawiki/services/eventstreams
Gerrit-Branch: master
Gerrit-Owner: Ottomata
___
MediaWiki-commits mailing list
MediaWiki-commits@lists.wikimedia.org
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
