Можем ли мы получить доступ к Healthcheck Rest API от Kafka?

Question

Хотелось бы знать, можем ли мы предоставить некоторые API REST от Kafka, которые можно использовать для проверки работоспособности или что-то в этом роде?

Если не нашли ни одного блога с соответствующей информацией.

Answer 1

Если вам просто необходим REST API для проверки работоспособности, вам может понадобиться следующий репозиторий: https://github.com/andreas-schroeder/kafka-health-check

Answer 2

Вы можете добавить агентов JMX, таких как Jolokia или экспортеры JMX Prometheus, которые предоставляют все данные JMX через HTTP.

Оттуда вы можете, например, собирать эти данные в Prometheus Server и сопоставлять то, что определяет нездоровые данные.кластер, такой как URP или использование высокой кучи, и т.д.

Confluent предлагает Центр управления, который может предоставлять некоторый уровень работоспособности кластера из API

Answer 3

Kafka не предоставляет REST API, но Confluent разработала REST-прокси для производства / потребления из Kafka.Однако он не предоставляет информацию о проверке работоспособности.

Это зависит от того, что вы подразумеваете под проверкой работоспособности, но Kafka Monitor от Linkedin довольно неплохо иметь сквозное представление о вашем кластере.