From 984a2faea97628b9fb4d2b33df1b242433c24d7d Mon Sep 17 00:00:00 2001 From: jqin Date: Fri, 23 Jan 2015 14:29:27 -0800 Subject: [PATCH] patch for KAFKA-1896 --- 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 3ee84ed..81ae205 100644 --- a/core/src/main/scala/kafka/tools/MirrorMaker.scala +++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala @@ -637,7 +637,7 @@ object MirrorMaker extends Logging with KafkaMetricsGroup { val sourceOffset: Long, val key: Array[Byte], val value: Array[Byte]) { - def size = value.length + {if (key == null) 0 else key.length} + def size = {if (value == null) 0 else value.length} + {if (key == null) 0 else key.length} } private class UnackedOffset(offset: Long) extends DoublyLinkedListNode[Long](offset) { -- 1.8.3.4 (Apple Git-47)