florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r786289278
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -264,39 +278,92 @@ object ConsoleProducer {
var reader:
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r785328925
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -264,39 +278,92 @@ object ConsoleProducer {
var reader:
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r764457132
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -206,11 +210,25 @@ object ConsoleProducer {
.describedAs("size")
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r764457132
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -206,11 +210,25 @@ object ConsoleProducer {
.describedAs("size")
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r773067418
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -29,8 +25,16 @@ import kafka.utils.{CommandDefaultOptions,
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r773067418
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -29,8 +25,16 @@ import kafka.utils.{CommandDefaultOptions,
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r764457132
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -206,11 +210,25 @@ object ConsoleProducer {
.describedAs("size")
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r763391826
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -264,38 +282,113 @@ object ConsoleProducer {
var reader:
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r763390871
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -264,38 +282,113 @@ object ConsoleProducer {
var reader:
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r762369085
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -274,28 +296,74 @@ object ConsoleProducer {
parseKey =
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r762368709
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -274,28 +296,74 @@ object ConsoleProducer {
parseKey =
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r762368709
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -274,28 +296,74 @@ object ConsoleProducer {
parseKey =
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r762369085
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -274,28 +296,74 @@ object ConsoleProducer {
parseKey =
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r762368754
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -208,9 +213,22 @@ object ConsoleProducer {
.defaultsTo(1024*100)
florin-akermann commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r762368709
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -274,28 +296,74 @@ object ConsoleProducer {
parseKey =
15 matches
Mail list logo