You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2018/04/23 18:42:21 UTC
[kafka] branch trunk updated: MINOR: Fix formatting in
--new-consumer deprecation warning (#4903)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 35c75ea MINOR: Fix formatting in --new-consumer deprecation warning (#4903)
35c75ea is described below
commit 35c75ea5036fbffe6ac74fe4f76a633bda061fec
Author: Patrik Erdes <pa...@erdes.se>
AuthorDate: Mon Apr 23 20:42:17 2018 +0200
MINOR: Fix formatting in --new-consumer deprecation warning (#4903)
---
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala | 4 ++--
core/src/main/scala/kafka/tools/ConsoleConsumer.scala | 2 +-
core/src/main/scala/kafka/tools/ConsumerPerformance.scala | 4 ++--
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala b/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
index cb9fbe3..689a63c 100755
--- a/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
+++ b/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
@@ -1017,8 +1017,8 @@ object ConsumerGroupCommand extends Logging {
CommandLineUtils.checkRequiredArgs(parser, options, bootstrapServerOpt)
if (options.has(newConsumerOpt)) {
- Console.err.println(s"The $newConsumerOpt option is deprecated and will be removed in a future major release." +
- s"The new consumer is used by default if the $bootstrapServerOpt option is provided.")
+ Console.err.println(s"The --new-consumer option is deprecated and will be removed in a future major release. " +
+ s"The new consumer is used by default if the --bootstrap-server option is provided.")
}
if (options.has(deleteOpt) && options.has(topicOpt))
diff --git a/core/src/main/scala/kafka/tools/ConsoleConsumer.scala b/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
index 5139324..7675d92 100755
--- a/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
+++ b/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
@@ -453,7 +453,7 @@ object ConsoleConsumer extends Logging {
CommandLineUtils.checkRequiredArgs(parser, options, bootstrapServerOpt)
if (options.has(newConsumerOpt)) {
- Console.err.println("The --new-consumer option is deprecated and will be removed in a future major release." +
+ Console.err.println("The --new-consumer option is deprecated and will be removed in a future major release. " +
"The new consumer is used by default if the --bootstrap-server option is provided.")
}
}
diff --git a/core/src/main/scala/kafka/tools/ConsumerPerformance.scala b/core/src/main/scala/kafka/tools/ConsumerPerformance.scala
index 7e0dbcb..d2aeab7 100644
--- a/core/src/main/scala/kafka/tools/ConsumerPerformance.scala
+++ b/core/src/main/scala/kafka/tools/ConsumerPerformance.scala
@@ -318,8 +318,8 @@ object ConsumerPerformance extends LazyLogging {
CommandLineUtils.checkRequiredArgs(parser, options, bootstrapServersOpt)
if (options.has(newConsumerOpt)) {
- Console.err.println("The --new-consumer option is deprecated and will be removed in a future major release." +
- "The new consumer is used by default if the --bootstrap-server option is provided.")
+ Console.err.println("The --new-consumer option is deprecated and will be removed in a future major release. " +
+ "The new consumer is used by default if the --broker-list option is provided.")
}
import org.apache.kafka.clients.consumer.ConsumerConfig
--
To stop receiving notification emails like this one, please contact
jgus@apache.org.