THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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 |
...