Kafka连接如何为连接器启用jmx度量

hjzp0vay  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(423)

如何为kafka连接器启用jmx度量?我正在运行分布式连接。
我通过启用 JMX_PORTkafka-run-class.sh .
现在,虽然它已经开始给我很多Kafka相关的指标,但我仍然看不到下面链接中提到的连接器特定指标http://kafka.apache.org/documentation.html#connect_monitoring.
以下域可用
JM实施
com.sun.management公司
java.lang语言
java.nio文件
java.util.logging文件
Kafka
Kafka集群
Kafka控制器
Kafka协调小组
Kafka事务处理
Kafka日志
Kafka网络
Kafka服务器
Kafka.utils

flmtquvp

flmtquvp1#

注解中提到的ask-您确定您连接到了正确的java示例而不是kafka代理jmx度量吗?因为 kafka.server 也不是 kafka.controller 不应该存在于connectdistributed进程中(您应该查看您所连接到的进程的主类)
只有一处房产, JMX_PORT ,它由kafka代理和kafka连接器(以及zookeeper、schema registry、ksql等)共享。。。如果不为每个进程使用不同的端口,则尝试运行的下一个进程都将无法启动,表示某个端口已打开
如果您有可用的硬件,或者可以在一台机器(docker或vm)上隔离组件,那么这是重新Map端口的简单方法。
否则,你就得做些

export JMX_PORT=35000 # pick a number 
zookeeper-server-start...
export JMX_PORT=35001 # pick a number 
kafka-server-start... 
export JMX_PORT=35002 # pick a number 
connect-distributed...

然后,连接到每个jvm的适当端口
然后,当您对此感到满意时,我建议您在生产部署设置上找到合流白皮书,其中connect(至少与所有其他生产者和消费者一样)正在脱离实际的代理。

相关问题