THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
Schema: { "fields": [ {"name": "version", "type": "int", "doc": "version id"}, {"name": "isr", "type": {"type": "array", "items": "int", "doc": "an array of the id of replicas in isr"} }, {"name": "leader", "type": "int", "doc": "id of the leader replica"}, {"name": "controllerEpochcontroller_epoch", "type": "int", "doc": "epoch of the controller that last updated the leader and isr info"}, {"name": "leaderEpochleader_epoch", "type": "int", "doc": "epoc of the leader"} ] } Example: { "version": 1, "isr": [0,1], "leader": 0, "controllerEpochcontroller_epoch": 1, "leaderEpochleader_epoch": 0 } |
Wiki Markup |
---|
3. Broker registration info: /brokers/ids/\[brokerId\] |
Code Block |
---|
Schema: { "fields": [ {"name": "version", "type": "int", "doc": "version id"}, {"name": "host", "type": "string", "doc": "ip address or host name of the broker"}, {"name": "port", "type": "int", "doc": "port of the broker"}, {"name": "jmxPortjmx_port", "type": "int", "doc": "port for jmx"} ] } Example: { "version": 1, "host": "192.168.1.148", "port": 9092, "jmxPortjmx_port": 9999 } |
4. Controller epoch:
...
Wiki Markup |
---|
/consumers/\[groupId\]/offsets/\[topic\]/\[partitionId\] \-> long (offset) |
9. Re-assign partitions: to be documented
/admin/reassign_partitions
10. Preferred replication election: to be documented
/admin/preferred_replica_election