Returns the message api key number.

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

Response content fields:

• throttle_time_ms: The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota. (int32 | versions 0+)

• topics: Each topic in the response. ([]DescribeTopicPartitionsResponseTopic | versions 0+)

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

  • name: The topic name. (string | versions 0+)

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

  • is_internal: True if the topic is internal. (bool | versions 0+)

  • partitions: Each partition in the topic. ([]DescribeTopicPartitionsResponsePartition | versions 0+)

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

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

    • leader_id: The ID of the leader broker. (int32 | versions 0+)

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

    • replica_nodes: The set of all nodes that host this partition. ([]int32 | versions 0+)

    • isr_nodes: The set of nodes that are in sync with the leader for this partition. ([]int32 | versions 0+)

    • eligible_leader_replicas: The new eligible leader replicas otherwise. ([]int32 | versions 0+)

    • last_known_elr: The last known ELR. ([]int32 | versions 0+)

    • offline_replicas: The set of offline replicas of this partition. ([]int32 | versions 0+)

  • topic_authorized_operations: 32-bit bitfield to represent authorized operations for this topic. (int32 | versions 0+)

• next_cursor: The next topic and partition index to fetch details for. (Cursor | versions 0+)

  • topic_name: The name for the first topic to process (string | versions 0+)

  • partition_index: The partition index to start with (int32 | 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:

• topics: The topics to fetch details for. ([]TopicRequest | versions 0+)

  • name: The topic name (string | versions 0+)

• response_partition_limit: The maximum number of partitions included in the response. (int32 | versions 0+)

• cursor: The first topic and partition index to fetch details for. (Cursor | versions 0+)

  • topic_name: The name for the first topic to process (string | versions 0+)

  • partition_index: The partition index to start with (int32 | versions 0+)