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 <[email protected]> Authored: Tue Aug 19 17:53:21 2014 -0700 Committer: Jun Rao <[email protected]> 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 {
