Repository: kafka Updated Branches: refs/heads/trunk b16817a54 -> 6a1993b8e
KAFKA-2862: Fix MirrorMaker's message.handler.args description Author: Ashish Singh <[email protected]> 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 <[email protected]> Authored: Fri Nov 20 15:59:24 2015 -0800 Committer: Guozhang Wang <[email protected]> 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])
