root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix formatting in --new-consumer deprecation warning (#4903)

This commit is contained in:
Patrik Erdes 2018-04-23 20:42:17 +02:00 committed by Jason Gustafson
parent ed51b2cdf5
commit 35c75ea503
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
View File

@ -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))

2
core/src/main/scala/kafka/tools/ConsoleConsumer.scala
View File

@ -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.")
}
}

4
core/src/main/scala/kafka/tools/ConsumerPerformance.scala
View File

@ -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