From 73604878838f4f852ceab731444e3a19922a27a8 Mon Sep 17 00:00:00 2001 From: Kamal Chandraprakash Date: Wed, 24 Feb 2021 18:20:35 +0530 Subject: [PATCH 1/2] MINOR: Changed the batch-size description as unused in console producer. --- core/src/main/scala/kafka/tools/ConsoleProducer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/tools/ConsoleProducer.scala b/core/src/main/scala/kafka/tools/ConsoleProducer.scala index 7c221baf69a2b..ec5cad3266c24 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", "Not used, reserved for backward compatibility. Use max-partition-memory-bytes to batch/group the messages.") .withRequiredArg .describedAs("size") .ofType(classOf[java.lang.Integer]) From 7864688860d3ed83308c1a317ddc142c6162f894 Mon Sep 17 00:00:00 2001 From: Kamal Chandraprakash Date: Wed, 24 Feb 2021 18:27:22 +0530 Subject: [PATCH 2/2] MINOR: Deprecate the 'batch-size' option in console producer. --- core/src/main/scala/kafka/tools/ConsoleProducer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/tools/ConsoleProducer.scala b/core/src/main/scala/kafka/tools/ConsoleProducer.scala index ec5cad3266c24..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", "Not used, reserved for backward compatibility. Use max-partition-memory-bytes to batch/group the messages.") + 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])