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

Apache Kafka代理未将指标发送到Confluent控制面板

丁曦哲
2023-03-14

我已经部署了一个带有映像confluentinc/cp enterprise Kafka的5代理Apache Kafka群集,以及一个带有confluentinc/cp enterprise Control center映像的Confluent控制面板容器,以获取以下说明https://docs.confluent.io/current/installation/docker/docs/quickstart.html#getting-从docker客户端开始

我在每个节点中激活了以下度量支持,并重新启动了它们:

##################### Confluent Metrics Reporter #######################
# Confluent Control Center and Confluent Auto Data Balancer integration
#
# Uncomment the following lines to publish monitoring data for
# Confluent Control Center and Confluent Auto Data Balancer
# If you are using a dedicated metrics cluster, also adjust the settings
# to point to your metrics kakfa cluster.
metric.reporters=io.confluent.metrics.reporter.ConfluentMetricsReporter
confluent.metrics.reporter.bootstrap.servers=localhost:9092
#
# Uncomment the following line if the metrics cluster has a single broker
#confluent.metrics.reporter.topic.replicas=1

##################### Confluent Proactive Support ######################
# If set to true, and confluent-support-metrics package is installed
# then the feature to collect and report support metrics
# ("Metrics") is enabled.  If set to false, the feature is disabled.
#
confluent.support.metrics.enable=true

但是:

>

我在Confluent Control Center日志中收到一条警告:

[2018-06-19 16:56:35739]WARN broker=1008未使用ConfluentMetricsReporter(io.confluent.controlcenter.healthcheck.healthcheck)进行检测

[2018-06-19 16:56:35739]WARN broker=1009未使用ConfluentMetricsReporter(io.confluent.controlcenter.healthcheck.healthcheck)进行检测

[2018-06-19 16:56:35,739]WARN代理=1006没有使用ConFluentMetricsReport(io.confluent.controlcenter.healthcheck.HealthCheck)进行检测

[2018-06-19 16:56:35,739]WARN代理=1010没有使用ConFluentMetricsReport(io.confluent.controlcenter.healthcheck.HealthCheck)进行检测

[2018-06-19 16:56:35739]WARN broker=1007未使用ConfluentMetricsReporter(io.confluent.controlcenter.healthcheck.healthcheck)进行检测

显然,我得到了火箭的图像

我遵循了以下指示,但什么也没有。

  • https://docs.confluent.io/current/control-center/docs/installation/troubleshooting.html
  • https://docs.confluent.io/current/kafka/metrics-reporter/metrics-reporter.html

这是我用来运行Apache Kafka容器的Docker命令:

docker run -d --net=confluent  --name=kafka1 -e KAFKA_ZOOKEEPER_CONNECT=zookeeper1:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka1:9092 confluentinc/cp-enterprise-kafka

谁能帮帮我吗?

共有1个答案

洪弘亮
2023-03-14

我会指出显而易见的。

每个代理都需要配置该属性文件,而不仅仅是一个。

每次更改该文件后,都需要重新启动Kafka。因为您使用的是Docker,所以您需要尊重不要删除Kafka主题数据(例如,使用卷装载)

您需要为指标报告器列出所有五个引导服务器的逗号分隔列表,而不仅仅是localhost

 类似资料:
  • 我正在使用docker运行datadog代理 我想使用dogstatsd发送自定义指标。当我运行 我可以在wireshark中看到,udp数据包成功地从源到目标,但这个指标没有提交给datadog。我缺少一些配置吗?

  • 我有一个controller类,如下所示: 我正在尝试添加一个方面,如下所示: 但是,没有调用aspect方法。我期望它在调用控制器的时执行。 我看到spring mvc没有用代理包装我的控制器bean。这就是为什么这方面没有效果的原因吗? 有没有人能解释一下我怎样才能让这个方面。 控制器类位于:com.xyz.webapp.controller中 Aspect类在com.xyz.webapp中

  • 如何通过Ajax调用将jsonArray发布到spring控制器?? 这是我的JSON数组想通过这个!!

  • 我有两个实体A和B,其中A拥有B类的属性“B ”( A和B之间一对一的关联) 我想做一个Rest调用来保存A实体的实例,并将b param作为url传递,该url在json中给出类似的东西: /b/2引用B储存库的findById rest资源。 当我执行A Repository的这个目标rest resource save()(通常是对url/restapi/A的POST请求)时,它工作得很好,

  • 我是百里香菜鸟。我试图创建一个简单的crud应用程序。我试图在删除按钮上删除客户类的对象。我如何使用百里香叶为调用deleteUser的方法设置参数(例如- id)。这是我的控制器。 以下是我的看法。

  • Spring-Boot执行器在中公开了许多有用的指标,例如正常运行时间、内存使用情况、GC计数。 在使用Dropwizard Metrics集成时,只有其中的一部分被发送到Graphite。具体来说,只有计数器和仪表 有什么方法可以将这些其他指标发布到石墨上吗? 文件表明,应该可以: Dropwizard“Metrics”库的用户会发现Spring Boot指标会自动发布到com。科达哈尔。韵律学