[GitHub] [kafka] mimaison commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

2022-01-13 Thread GitBox
mimaison commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r784199669 ## File path: core/src/test/scala/unit/kafka/tools/LineMessageReaderTest.scala ## @@ -0,0 +1,210 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] [kafka] mimaison commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

2022-01-03 Thread GitBox
mimaison commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r777502237 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -29,8 +25,16 @@ import kafka.utils.{CommandDefaultOptions, CommandLineUtils,

[GitHub] [kafka] mimaison commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

2021-12-14 Thread GitBox
mimaison commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r768431335 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -29,8 +25,16 @@ import kafka.utils.{CommandDefaultOptions, CommandLineUtils,

[GitHub] [kafka] mimaison commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

2021-12-09 Thread GitBox
mimaison commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r765876199 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -206,11 +210,25 @@ object ConsoleProducer { .describedAs("size")

[GitHub] [kafka] mimaison commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

2021-12-06 Thread GitBox
mimaison commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r763051523 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -206,11 +210,25 @@ object ConsoleProducer { .describedAs("size")