当前位置: 首页 > 知识库问答 >
问题:

Kafka Connect-通过JMX的指标

暴才俊
2023-03-14

我正在使用融合HDFS接收器连接器,想知道如何通过JMX或REST API公开消费者属性。

我检查了以下两个属性,但是,我不知道如何将指标公开到 jmx 端口

    < Li > connect-standalone . properties < li >消费者.属性

共有2个答案

钦德佑
2023-03-14

几天前也遇到了同样的问题——这个堆栈溢出链接有一种解决问题的方法。它能够使用jmx导出器公开指标,这被普罗米修斯刮掉了。

萧阳波
2023-03-14

在启动 Kafka Connect 时设置JMX_PORT。例如

export JMX_PORT=4242
./bin/connect-distributed ./etc/kafka/connect-distributed.properties

然后,您可以使用JConsole、JMXTerm等连接到JMX。

 类似资料:
  • weblogic是否通过Jmx公开指标,以便可以使用prometheus进行监控?监视weblogic服务器(线程、数据源…)的最佳解决方案是什么?

  • 我们有多个基于Web逻辑和Tomcat的应用程序。对于这些具有不同垃圾收集格式的不同java应用程序,获得用于监视堆问题、占用线程等的“标准”方法的典型解决方案是什么。 通常我想做的是从这些应用程序中获取最后一次完全垃圾收集和常规垃圾收集条目,并从它们中获取初始最大值。进行计算,将数据保存到进行报告,并在达到阈值时生成警报。 最好的方法是什么? 谢谢博帕利

  • 我使用的是Artemis1.3,我希望使用jConsole来监视它(正如《如何监视Apache Artemis》中提出的那样)。 我通常能够连接到Artemis,但我对它的用法有一些问题。(这些问题主要是对接口的问题,因为我认为这些方法将通过JMX调用): 2)“ListMessages”的筛选器参数是什么?只有当我将其设置为null时,才会得到一个响应,但是每隔一个值,我只会得到一个空结果。

  • 我已经从一台没有SSL的机器连接了一个JMX连接。但是当我给出SSL时,尽管应用程序没有任何错误地启动,VisualVM无法通过指定的端口建立JMX连接。下面是我用来从应用程序端建立JMX连接的命令。 java-dcom.sun.management.jmxremote.port=4444-dcom.sun.management.jmxremote.password.file=“C://Progr

  • 所有的, 我需要将 Apache Kafka 指标公开给Spring启动 (v 2.3.0.RELEASE) 致动器endpoint。 请注意,我没有使用库。 我正在使用以下库: 我已经试过这个< code > spring . JMX . enabled = true 了,但是好像没有用。我认为这是因为Spring没有管理Kafka。 有没有一种方法可以将这些JMX度量绑定到千分尺注册表? 我可

  • 我参考了以下链接来了解Kafka的HDFS连接https://docs.confluent.io/2.0.0/Connect/connect-hdfs/docs/index.html 我能够通过配置单元集成将数据从Kafka导出到HDFS。 现在我正尝试在Java程序的帮助下将avro记录写入Kafka 当我把Avro记录写到Kafka主题时,我在Connect中出现以下错误