kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix formatting in --new-consumer deprecation warning (#4903)
Date Mon, 23 Apr 2018 18:42:21 GMT
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 <patrik@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.

Mime
View raw message