...
| Code Block | ||
|---|---|---|
| ||
{
"version": 4,
"jmx_port": 9999,
"timestamp": 2233345666,
"host": "localhost",
"port": 9092,
"rack": "rack1",
"listener_security_protocol_map": {
"PLAINTEXT": "PLAINTEXT",
"SSL": "SSL",
"SASL_PLAINTEXT": "SASL_PLAINTEXT",
"SASL_SSL": "SASL_SSL"
},
"endpoints": [
"CLIENT://cluster1.foo.com:9092",
"REPLICATION: //broker1.replication.local:9093",
"INTERNAL_PLAINTEXT: //broker1.local:9094",
"INTERNAL_SASL://broker1.local:9095"
]
} |
Protocol
Version 2 3 of UpdateMetadataRequest will be introduced and the elements of the end_points array would also have a listener_name field.
| Code Block |
|---|
UpdateMetadata Request (Version: 23) => controller_id controller_epoch [partition_states] [live_brokers] controller_id => INT32 controller_epoch => INT32 partition_states => topic partition controller_epoch leader leader_epoch [isr] zk_version [replicas] topic => STRING partition => INT32 controller_epoch => INT32 leader => INT32 leader_epoch => INT32 isr => INT32 zk_version => INT32 replicas => INT32 live_brokers => id [end_points] id => INT32 end_points => port host listener_name (new) security_protocol_type port => INT32 host => STRING listener_name => String (new) security_protocol_type => INT16 |
...