检索 kafka 集群版本的最简单解决方案是使用每个代理公开的 JMX 指标。通常,JMX 在代理上激活以用于监控目的。
每个代理可以通过指标名称公开版本:
kafka.server:type=app-info,version=<([-.\w]+)>
Run Code Online (Sandbox Code Playgroud)
为此,您可以使用Apache/Confluence Kafka 发行版中提供的jconsole或JmxTool 。
这是一个例子:
$> ./bin/kafka-run-class kafka.tools.JmxTool --jmx-url service:jmx:rmi:///jndi/rmi://:9999/jmxrmi --object-name kafka.server:type=app-info --attributes version
Run Code Online (Sandbox Code Playgroud)
这会给你一个输出:
Trying to connect to JMX url: service:jmx:rmi:///jndi/rmi://:9999/jmxrmi.
"time","kafka.server:type=app-info:version"
1556186760721,2.1.0-cp1
1556186762728,2.1.0-cp1
1556186764727,2.1.0-cp1
Run Code Online (Sandbox Code Playgroud)
--jmx-url请注意,您应该使用自己的环境信息配置该属性。
| 归档时间: |
|
| 查看次数: |
5603 次 |
| 最近记录: |