Returns the message api key number.

Receive a binary in the kafka wire format and deserialize it into a map.

Response content fields:

• results: The read results. ([]ReadStateSummaryResult | versions 0+)

  • topic_id: The topic identifier. (uuid | versions 0+)

  • partitions: The results for the partitions. ([]PartitionResult | versions 0+)

    • partition: The partition index. (int32 | versions 0+)

    • error_code: The error code, or 0 if there was no error. (int16 | versions 0+)

    • error_message: The error message, or null if there was no error. (string | versions 0+)

    • state_epoch: The state epoch of the share-partition. (int32 | versions 0+)

    • start_offset: The share-partition start offset. (int64 | versions 0+)

Returns the current max supported version of this message.

Returns the current min supported version of this message.

Receives a map and serialize it to kafka wire format of the given version.

Input content fields:

• group_id: The group identifier. (string | versions 0+)

• topics: The data for the topics. ([]ReadStateSummaryData | versions 0+)

  • topic_id: The topic identifier. (uuid | versions 0+)

  • partitions: The data for the partitions. ([]PartitionData | versions 0+)

    • partition: The partition index. (int32 | versions 0+)

    • leader_epoch: The leader epoch of the share-partition. (int32 | versions 0+)