KAFKA-6733: Printing additional ConsumerRecord fields in DefaultMessageFormatter (#9099)
Implementation of KIP-431 - Support of printing additional ConsumerRecord fields in DefaultMessageFormatter https://cwiki.apache.org/confluence/display/KAFKA/KIP-431%3A+Support+of+printing+additional+ConsumerRecord+fields+in+DefaultMessageFormatter Reviewers: David Jacot <djacot@confluent.io>, Bill Bejeck <bbejeck@gmail.com>
显示
- core/src/main/scala/kafka/tools/ConsoleConsumer.scala 112 个添加, 62 个删除core/src/main/scala/kafka/tools/ConsoleConsumer.scala
- core/src/test/scala/kafka/tools/DefaultMessageFormatterTest.scala 237 个添加, 0 个删除.../test/scala/kafka/tools/DefaultMessageFormatterTest.scala
- core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala 9 个添加, 3 个删除...src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala
加载中
想要评论请 注册 或 登录