我正在我们的Kafka生态系统中为Kafka connect设置监控。我已经启用了JMX出口商为Kafka经纪人,工作很好。现在,我正试图使JMX出口Kafka连接。但是,从哪里开始有点不清楚。
我只能修改< code > connect-distributed . sh 来启用更改。任何指针将是一个伟大的补充。
<code>kafka运行类。sh被修改为使jmx_exporter
能够在http://
我希望kafka-connect在< code>http://上发出度量
深入研究后,我找到了解决这个问题的方法。Java代理可以添加到connect-distributed.sh
并开始很好地发出指标。
因此,在Kafka Connect框架上启用< code>jmx_exporter
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 "$@"
非常不建议修改bin
目录中的脚本。当将Kafka升级到下一版本时,提取新的二进制文件将覆盖脚本中所做的更改。
首选的方法应该是在脚本外部设置环境变量KAFKA_JMX_OPTS
:
export 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
中定义的默认值
这个答案的灵感来源于我如何为Kafka设置Java选项?
我正在尝试导出kafka连接指标。我的解决方案包括运行jmx导出器,并在endpoint处公开它们,然后可以使用Prometheus擦除。现在,我可以对我尝试过的所有指标都这样做,但对于一组指标,它不起作用。我对这组指标的导出配置如下 根据官方文档,这些指标的定义如下所示: 我想模式选择有问题,但我无法弄清楚是什么。请提供任何帮助或建议!!
我无法导出合流连接服务的“type=connector-metrics”指标,但其他指标工作正常。 我正在使用Prometheus导出器java代理来公开来自Confluent connect的指标,如下所示。 export KAFKA_OPTS='-javaagent:/opt/prometheus/jmx_prometheus_javaagent-0.12.0.jar=8093:/opt/普罗
大概是这样的: 谢谢[已解决] 也感谢Umer Farooq的回答:从lambda内部修改局部变量
如何为Kafka连接器启用jmx度量?我正在运行分布式连接。 我通过在中启用,为Kafka启用了jmx度量。 现在,尽管它已经开始为我提供很多与 Kafka 相关的指标,但我仍然看不到以下链接 http://kafka.apache.org/documentation.html#connect_monitoring 中提到的连接器特定指标。 下列域可用 JM实施 com.sun公司。管理 java
我们的Java应用程序使用jTDS 1.3.1连接到SQL服务器,在客户端尝试将数据库放在AzureSQL之前,该服务器运行良好。连接失败,但有以下例外: java.sql.SQLException:原因:由于客户端TLS版本低于服务器允许的最低TLS版本,登录失败。 我查看了jTDS的文档,无论如何都看不到指定TLS版本。除了用MS JDBC驱动程序替换它之外,还有人成功地解决了其他问题吗? 我
问题内容: 我有一堆规则要注入到一组类中,如下所示: 我怎样才能包括对应列出了常见的规则列表和? 规则的数量(例如rule1,rule2等)更多,而组的数量(normalInvRules,prepaidInvRules等)也更多。因此,我想知道是否有一种方法可以避免重复通用规则,而仅列出特定规则并包括对通用列表的引用。 问题答案: 确实有一个称为“集合合并”的功能。见3.3.3.4.1节。我就此主