kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2314: proper MirrorMaker's message handler help message; reviewed by Guozhang Wang
Date Tue, 07 Jul 2015 16:13:14 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 2d96da05a -> 271b18d11


KAFKA-2314: proper MirrorMaker's message handler help message; reviewed by Guozhang Wang


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

Branch: refs/heads/trunk
Commit: 271b18d119fdc37952c36c573ba185aa672e3f96
Parents: 2d96da0
Author: Kostya Golikov <johnysilver7@gmail.com>
Authored: Tue Jul 7 09:12:57 2015 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Jul 7 09:12:57 2015 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/MirrorMaker.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/271b18d1/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 459aaec..797b4bb 100755
--- a/core/src/main/scala/kafka/tools/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala
@@ -131,9 +131,9 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
       .ofType(classOf[String])
 
     val messageHandlerOpt = parser.accepts("message.handler",
-      "The consumer rebalance listener to use for mirror maker consumer.")
+      "Message handler which will process every record in-between consumer and producer.")
       .withRequiredArg()
-      .describedAs("A custom rebalance listener of type MirrorMakerMessageHandler")
+      .describedAs("A custom message handler of type MirrorMakerMessageHandler")
       .ofType(classOf[String])
 
     val messageHandlerArgsOpt = parser.accepts("message.handler.args",


Mime
View raw message