THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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": "jmx_port", "type": "int", "doc": "port for jmx"} {"name": "endpoints", "type": "array", "items": "string", "doc": "endpoints supported by the broker"} ] } Example: { "version":2, "host","localhost", "port",9092 "jmx_port":9999, "timestamp":"2233345666", "endpoints": ["PLAINTEXT://host1:9092", "SSL://host1:9093"] } |
ACL info. The content of these znodes have the same structure
/kafka-acl/Topic/[topic_name]
/kafka-acl/Cluster/kafka-cluster
/kafka-acl/Group/[groupId]
Code Block |
---|
{"version": 1, "acls": [ { "host":"host1", "permissionType": "Allow","operation": "Read","principal": "User:alice"}]} |
0.10
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": "jmx_port", "type": "int", "doc": "port for jmx"}
{"name": "endpoints", "type": "array", "items": "string", "doc": "endpoints supported by the broker"}
{"name": "rack", "type": "string", "doc": "Rack of the broker. Optional. This will be used in rack aware replication assignment for fault tolerance."}
]
}
Example:
{
"version":3,
"host":"localhost",
"port":9092,
"jmx_port":9999,
"timestamp":"2233345666",
"endpoints": ["PLAINTEXT://host1:9092", "SSL://host1:9093"],
"rack": "us-east-1c"
} |