From abfd9a94acd2c930e33bc8965356bd5acc6df18b Mon Sep 17 00:00:00 2001 From: Jiangjie Qin Date: Tue, 19 Aug 2014 14:45:45 -0700 Subject: [PATCH] pass message key to datachannel in mirror maker consumer thread. --- core/src/main/scala/kafka/tools/MirrorMaker.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 { -- 1.7.12.4