kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1603; MirrorMaker consumer does not put the message key into ProducerRecord; patched by Jiangjie Qin; reviewed by Jun Rao
Date Wed, 20 Aug 2014 00:53:28 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f402b7a96 -> a30491ac5


kafka-1603; MirrorMaker consumer does not put the message key into ProducerRecord; patched
by Jiangjie Qin; reviewed by Jun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a30491ac
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a30491ac
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a30491ac

Branch: refs/heads/trunk
Commit: a30491ac5d3fc5967e8c4b16c68bdbfc312748f5
Parents: f402b7a
Author: Jiangjie Qin <becket.qin@gmail.com>
Authored: Tue Aug 19 17:53:21 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Tue Aug 19 17:53:21 2014 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/MirrorMaker.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/a30491ac/core/src/main/scala/kafka/tools/MirrorMaker.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/MirrorMaker.scala b/core/src/main/scala/kafka/tools/MirrorMaker.scala
index 555d751..b8698ee 100644
--- a/core/src/main/scala/kafka/tools/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala
@@ -246,7 +246,7 @@ object MirrorMaker extends Logging {
       info("Starting mirror maker consumer thread " + threadName)
       try {
         for (msgAndMetadata <- stream) {
-          val data = new ProducerRecord(msgAndMetadata.topic, msgAndMetadata.message)
+          val data = new ProducerRecord(msgAndMetadata.topic, msgAndMetadata.key, msgAndMetadata.message)
           mirrorDataChannel.put(data)
         }
       } catch {


Mime
View raw message