...
UpdateMetadata Request (Version: 7) => controller_id controller_epoch broker_epoch [ungrouped_partition_states] [topic_states] [live_brokers]
controller_id => INT32
controller_epoch => INT32
broker_epoch => INT64
ungrouped_partition_states => UpdateMetadataPartitionState
topic_states => topic_name topic_id* [partition_states]
topic_name => STRING
topic_id* => UUID
partition_states => UpdateMetadataPartitionState
live_brokers => id v0_host v0_port [endpoints] rack
id => INT32
v0_host => STRING
v0_port => INT32
endpoints => port host listener security_protocol
port => INT32
host => STRING
listener => STRING
security_protocol => INT16
rack => STRING
|
Produce
Swapping a the topic name for the topic ID will cut down on the size of the request.
ProduceRequest v9
Produce Request (Version 9) => transactional_id acks timeout_ms [topics]
transactional_id => STRING
acks => INT16
timeout_ms => INT32
topics => topic_id* [partitions]
topic_id* => UUID
partitions => partition_index records
partition_index => INT32
records => BYTES
|
ProduceResponse v9
Produce Response (Version 9) => [responses] throttle_time_ms
responses => topic_id* [partitions]
topic_id* => UUID
partitions => partition_index error_code base_offset log_append_time_ms log_start_offset [record_errors] error_message
partition_index => INT32
error_code => INT16
base_offset => INT64
log_append_time_ms => INT64
log_start_offset => INT64
record_errors => batch_index batch_index_error_message
batch_index => INT32
batch_index_error_message => STRING
error_message => STRING
throttle_time_ms => INT32
|
DeleteTopics
With the addition of topic IDs and the changes to LeaderAndIsrRequest described above, we can now make changes to topic deletion logic that will allow topics to be immediately considered deleted, regardless of whether all replicas have responded to a DeleteTopicsRequest.
...
- CreatePartitionsRequest
- ElectPreferredLeadersRequest
- AlterReplicaLogDirsRequest
- AlterConfigsRequest
- DeleteTopicsRequest
- DescribeConfigsRequest
- DescribeLogDirsRequest
- DeleteRecordsRequestProduceRequest
- AddPartitionsToTxnRequest
- TxnOffsetCommitRequest
- WriteTxnMarkerRequest
...