You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/11/21 00:59:28 UTC
kafka git commit: KAFKA-2862: Fix MirrorMaker's message.handler.args
description
Repository: kafka
Updated Branches:
refs/heads/trunk b16817a54 -> 6a1993b8e
KAFKA-2862: Fix MirrorMaker's message.handler.args description
Author: Ashish Singh <as...@cloudera.com>
Reviewers: Guozhang Wang
Closes #561 from SinghAsDev/KAFKA-2862
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6a1993b8
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6a1993b8
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6a1993b8
Branch: refs/heads/trunk
Commit: 6a1993b8e08da1a4e8b5b7fbb55d777b70b1f6f5
Parents: b16817a
Author: Ashish Singh <as...@cloudera.com>
Authored: Fri Nov 20 15:59:24 2015 -0800
Committer: Guozhang Wang <gu...@Guozhang-Macbook.local>
Committed: Fri Nov 20 15:59:24 2015 -0800
----------------------------------------------------------------------
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/6a1993b8/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 6e54b85..35bdfc4 100755
--- a/core/src/main/scala/kafka/tools/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala
@@ -147,7 +147,7 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
.ofType(classOf[String])
val messageHandlerArgsOpt = parser.accepts("message.handler.args",
- "Arguments used by custom rebalance listener for mirror maker consumer")
+ "Arguments used by custom message handler for mirror maker.")
.withRequiredArg()
.describedAs("Arguments passed to message handler constructor.")
.ofType(classOf[String])