This is an automated email from the ASF dual-hosted git repository.
dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 529dde9 KAFKA-12648: handle MissingSourceTopicException for named
topologies (#11600)
add ed8b787 KAFKA-13351: Add possibility to write kafka headers in Kafka
Console Producer (KIP-798) (#11456)
No new revisions were added by this update.
Summary of changes:
.../main/scala/kafka/tools/ConsoleProducer.scala | 107 +++++++--
.../unit/kafka/tools/LineMessageReaderTest.scala | 247 +++++++++++++++++++++
2 files changed, 332 insertions(+), 22 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/tools/LineMessageReaderTest.scala
