Index: core/src/main/scala/kafka/tools/MirrorMaker.scala
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- core/src/main/scala/kafka/tools/MirrorMaker.scala	(revision 2d96da05a0af7847aca5edc6d003a18be7f5216a)
+++ core/src/main/scala/kafka/tools/MirrorMaker.scala	(revision )
@@ -131,9 +131,9 @@
       .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",