我正在为卡夫卡生态系统中的卡夫卡连接建立监控系统。我已经为卡夫卡经纪人启用了JMX出口商,而且运作良好。现在,我正在努力使JMX出口商的卡夫卡连接。然而,现在还不清楚从哪里开始。
我只能修改connect-distributed.sh
以启用更改。任何指针都是一个很好的补充。
对kafka-run-class.sh
进行了修改,使jmx_exporter
能够在http://<host>:9304/metrics
上发出jmx指标。
我希望卡夫卡-连接一旦启用了http://<host>:19000/metrics
,就会在jmx_exporter
上发布度量标准。
发布于 2020-02-26 15:43:09
强烈不建议修改bin
目录中的脚本。当将Kafka升级到下一个版本时,提取新的二进制文件将覆盖脚本中的更改。
首选的方法应该是在脚本之外设置环境变量KAFKA_JMX_OPTS
:
导出KAFKA_JMX_OPTS="-javaagent:/opt/kafka/libs/jmx_prometheus_javaagent-0.12.0.jar=127.0.0.1:10902:/etc/kafka-connect/jmx_exporter.yaml“
如果在通过脚本启动Kafka之前设置了var,那么它将使用var而不是/bin/kafka-server-start.sh
中定义的默认值。
发布于 2019-07-02 10:48:35
我已经找到了解决这个问题的办法。Java可以添加到connect-distributed.sh
中,并开始很好地发出度量。
因此,在Kafka框架上启用jmx_exporter
connect-distributed.sh
kafka-run-class.sh
exec $(dirname $0)/kafka-run-class.sh $EXTRA_ARGS org.apache.kafka.connect.cli.ConnectDistributed "$@"
到以下
exec $(dirname $0)/kafka-run-class.sh $EXTRA_ARGS -javaagent:/path/to/jmx_prometheus_javaagent-0.11.0.jar=9408:/path/to/config/file/prometheus.yml org.apache.kafka.connect.cli.ConnectDistributed "$@"
https://stackoverflow.com/questions/56835399
复制相似问题