xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668913284
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,18 @@ object ConsoleConsumer extends Logging {
formatter.config
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668872810
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -191,9 +191,15 @@ object ConsoleConsumer extends Logging {
.withRequiredArg
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668872338
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.config
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668869858
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,18 @@ object ConsoleConsumer extends Logging {
formatter.config
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668178829
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,21 @@ object ConsoleConsumer extends Logging {
formatter.config
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667362757
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,14 @@ object ConsoleConsumer extends Logging {
formatter.config
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667362757
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,14 @@ object ConsoleConsumer extends Logging {
formatter.config
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667078995
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -392,25 +401,25 @@ object ConsoleConsumer extends Logging {
}
}
- privat
xvrl commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667075504
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -191,9 +191,15 @@ object ConsoleConsumer extends Logging {
.withRequiredArg