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. ([]ReadStateResult | 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 for this share-partition. (int32 | versions 0+)

    • start_offset: The share-partition start offset, which can be -1 if it is not yet initialized. (int64 | versions 0+)

    • state_batches: The state batches for this share-partition. ([]StateBatch | versions 0+)

      • first_offset: The base offset of this state batch. (int64 | versions 0+)

      • last_offset: The last offset of this state batch. (int64 | versions 0+)

      • delivery_state: The state - 0:Available,2:Acked,4:Archived. (int8 | versions 0+)

      • delivery_count: The delivery count. (int16 | 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. ([]ReadStateData | 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+)