Decodes the group metadata messages' payload and retrieves its member metadatafrom it
Decodes the group metadata messages' payload and retrieves its member metadatafrom it
input byte-buffer
a group metadata object from the message
Decodes the offset messages' key
Decodes the offset messages' key
input byte-buffer
an GroupTopicPartition object
Decodes the offset messages' payload and retrieves offset and metadata from it
Decodes the offset messages' payload and retrieves offset and metadata from it
input byte-buffer
an offset-metadata object from the message
Messages stored for the group topic has versions for both the key and value fields. Key version is used to indicate the type of the message (also to differentiate different types of messages from being compacted together if they have the same field values); and value version is used to evolve the messages within their data types:
key version 0: group consumption offset -> value version 0: [offset, metadata, timestamp]
key version 1: group consumption offset -> value version 1: [offset, metadata, commit_timestamp, expire_timestamp]
key version 2: group metadata -> value version 0: [protocol_type, generation, protocol, leader, members]