Details
-
Improvement
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
None
-
None
-
None
Description
`GroupMetadataMessageFormatter`[0], `OffsetsMessageFormatter`[1], and `TransactionLogMessageFormatter`[2] are used by ConsoleConsumer to parse data of internal topics. Following the migration plan, we should move them to tools-api module. Also, we need to keep the compatibility of command line. That is to say, `ConsoleConsumer` can accept the previous package name and then use the (java) implementation to parse and make same output.
The Scala formatter output is not json format, thus the new Java formatter will leverage the protocol by json mechanism.
[0]
[0] https://github.com/apache/kafka/blob/376e9e20dbf7c7aeb6f6f666d47932c445eb6bd1/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala#L1269
[1] https://github.com/apache/kafka/blob/376e9e20dbf7c7aeb6f6f666d47932c445eb6bd1/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala#L1248
[2] https://github.com/apache/kafka/blob/9b8aac22ec7ce927a2ceb2bfe7afd57419ee946c/core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala#L145
Attachments
Issue Links
- breaks
-
KAFKA-17195 transaction-coordinator:test failing with junit error
- Resolved
- links to