root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity
kafka/share-coordinator/src
History
Sushant Mahajan 5545d717c3
KAFKA-17633: Add share group record formatter and parser. (#17467) 
As part of KIP-932, a new internal topic __share_group_state was introduced. There are 2 types of records which are currently being added in this topic - ShareSnapshotKey/Value and ShareUpdateKey/Value
In light of this, we must make the existing tooling like kafka-console-consumer and kafka-dump-log aware of these records for debugging and introspection purposes.
This PR introduces ShareGroupStateMessageFormatter to be used used with kafka-console-consumer and adds an internal class ShareGroupStateMessageParser in DumpLogSegments.scala.
Unit tests have been added to DumpLogSegmentsTest.scala


Reviewers:  Andrew Schofield <aschofield@confluent.io>,  Manikumar Reddy <manikumar.reddy@gmail.com>
 		2024-10-15 11:44:15 +05:30
..
main KAFKA-17633: Add share group record formatter and parser. (#17467) 2024-10-15 11:44:15 +05:30
test/java/org/apache/kafka/coordinator/share KAFKA-17633: Add share group record formatter and parser. (#17467) 2024-10-15 11:44:15 +05:30