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+)

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

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

• member_id: The member ID is generated by the consumer and provided by the consumer for all requests. (string | versions 0+)

• member_epoch: The member epoch. (int32 | versions 0+)

• heartbeat_interval_ms: The heartbeat interval in milliseconds. (int32 | versions 0+)

• assignment: null if not provided; the assignment otherwise. (Assignment | versions 0+)

  • topic_partitions: The partitions assigned to the member. ([]TopicPartitions | versions 0+)

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

    • partitions: The partitions. ([]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:

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

• member_id: The member id. (string | versions 0+)

• member_epoch: The current member epoch; 0 to join the group; -1 to leave the group. (int32 | versions 0+)

• rack_id: null if not provided or if it didn't change since the last heartbeat; the rack ID of consumer otherwise. (string | versions 0+)

• subscribed_topic_names: null if it didn't change since the last heartbeat; the subscribed topic names otherwise. ([]string | versions 0+)