我想知道我们是否可以从kafka公开一些restapi，这些api可以用于健康检查或其他类似的东西？如果没有找到任何提供相关信息的博客。
cedebl8k1#
kafka不提供restapi，但是confluent已经开发了一个rest代理来生成/使用kafka。但是它不提供健康检查信息。这取决于你所说的healthcheck是什么意思，但是linkedin的kafka monitor很好地提供了集群的端到端视图。
rwqw0loc2#
您可以添加jolokia或prometheus jmx exporters之类的jmx代理，它们通过http公开所有jmx数据。例如，您可以从那里将数据收集到prometheus服务器中，并关联定义不健康集群的内容，例如urp或高堆使用率等。基于非http/pull的解决方案也存在，比如telegraf或datadog。confluent提供了control center，它可能会从api中暴露某种级别的集群健康状况
rbpvctlc3#
如果您只需要rest api进行运行状况检查，那么您可能需要以下存储库：https://github.com/andreas-schroeder/kafka-health-check
3条答案
按热度按时间cedebl8k1#
kafka不提供restapi，但是confluent已经开发了一个rest代理来生成/使用kafka。但是它不提供健康检查信息。
这取决于你所说的healthcheck是什么意思，但是linkedin的kafka monitor很好地提供了集群的端到端视图。
rwqw0loc2#
您可以添加jolokia或prometheus jmx exporters之类的jmx代理，它们通过http公开所有jmx数据。
例如，您可以从那里将数据收集到prometheus服务器中，并关联定义不健康集群的内容，例如urp或高堆使用率等。
基于非http/pull的解决方案也存在，比如telegraf或datadog。
confluent提供了control center，它可能会从api中暴露某种级别的集群健康状况
rbpvctlc3#
如果您只需要rest api进行运行状况检查，那么您可能需要以下存储库：https://github.com/andreas-schroeder/kafka-health-check