Generates the key for offset commit message for given (group, topic, partition)
Generates the key for offset commit message for given (group, topic, partition)
key for offset commit message
Generates the payload for offset commit message from given offset and metadata
Generates the payload for offset commit message from given offset and metadata
consumer's current offset and metadata
payload for offset commit 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