You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 2 Next »

0.8:

1. Topic registration info:
/brokers/topics/[topic] :

Schema:
{ "fields" :
    [ {"name": "version", "type": "int", "doc": "version id"},
      {"name": "partitions",
        "type": {"type" : "array",
                  "items" : {"type": "map",
                             "values": {"type": "array", "items": "int", "doc": "a list of replica ids"},
                             "doc": "a map from partition id to replica list"},
                  "doc": "a list of partitions"},
      }
    ]
}
Example:
{
  "version": 1,
  "partitions": ["0": [0, 1, 3] ] }
}

2. Leader and isr info:
/brokers/topics/test/partitions/[partition-id]/leaderAndIsr

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": "controllerEpoch", "type": "int", "doc": "epoch of the controller that last updated the leader and isr info"},
      {"name": "leaderEpoch", "type": "int", "doc": "epoc of the leader"}
    ]
}

Example:
{
  "version": 1,
  "isr": [0,1],
  "leader": 0,
  "controllerEpoch": 1,
  "leaderEpoch": 0
}

3. Broker registration info:
/brokers/ids/[broker-id]

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": "jmxPort", "type": "int", "doc": "port for jmx"}
    ]
}

Example:
{
  "version": 1,
  "host": "192.168.1.148",
  "port": 9092,
  "jmxPort": 9999
}
  • No labels