diff --git a/core/src/main/scala/kafka/tools/ConsoleProducer.scala b/core/src/main/scala/kafka/tools/ConsoleProducer.scala index 7c221baf69a2b..4dcabaf8b653a 100644 --- a/core/src/main/scala/kafka/tools/ConsoleProducer.scala +++ b/core/src/main/scala/kafka/tools/ConsoleProducer.scala @@ -141,7 +141,7 @@ object ConsoleProducer { .withOptionalArg() .describedAs("compression-codec") .ofType(classOf[String]) - val batchSizeOpt = parser.accepts("batch-size", "Number of messages to send in a single batch if they are not being sent synchronously.") + val batchSizeOpt = parser.accepts("batch-size", "DEPRECATED, use --max-partition-memory-bytes instead; to batch/group the messages.") .withRequiredArg .describedAs("size") .ofType(classOf[java.lang.Integer])