Учитывая хост / IP-адрес брокера, есть ли способ опросить его, чтобы узнать идентификатор брокера, кроме запроса ZK? Я пытаюсь сопоставить IP-адрес с идентификатором брокера для мониторинга. ZK аутентифицирован, и у меня нет доступа. Я предпочтительно ищу значение в JMX.
Значения JMX содержат имя хоста kafka: Advertised.host.name или java.net.InetAddress.getCanonicalHostName ().
Посмотри сюда http://kafka.apache.org/090/documentation.html#brokerconfigs
Вы можете использовать этот шаблон kafka.server:type=app-info,id=* для получения идентификатора брокера.
При отправке на брокер 1с Jolokia конечная точка, вот что она возвращает:
{
"request": {
"mbean": "kafka.server:id=*,type=app-info",
"type": "read"
},
"value": {
"kafka.server:id=1,type=app-info": {
"StartTimeMs": 1575897801771,
"Version": "2.3.1",
"CommitId": "18a913733fb71c01"
}
},
"timestamp": 1576320157,
"status": 200
}