我听说如果我使用的是基于java的kafka使用者,我可以通过添加一些参数来公开jmx度量(在这里和其他一些帖子中都听说了)
我的Kafka消费者正在码头里面运行。
下面是我要添加的四个参数:
-Dcom.sun.management.jmxremote.port=1100
-Dom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
-Dcom.sun.management.jmxremote.local.only=false
我正在把它添加到dockerfile的入口点。但我的jconsole无法连接到它。
这是我的dockerfile和我的docker compose相关服务:
FROM openjdk:8u181-jre
ADD ./app /app
ENTRYPOINT [ "java", "-jar", "-Dcom.sun.management.jmxremote.port=1100", "-Dcom.sun.management.jmxremote.authenticate=false", "-Dcom.sun.management.jmxremote.ssl=false", "-Dcom.sun.management.jmxremote.local.only=false", "/app/KafkaConsumer.jar" ]
jk_cons:
build: ./micro_services/jk_Cons
ports:
- "1100:1100"
volumes:
- /neito/shared/linux_shared/historian/logging:/app
有人能告诉我如何通过jmx公开kafka消费者指标吗?
祝您有个美好的一天
暂无答案!
目前还没有任何答案,快来回答吧!