我已经部署了一个带有映像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)进行检测
显然,我得到了火箭的图像
我遵循了以下指示,但什么也没有。
这是我用来运行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
谁能帮帮我吗?
我会指出显而易见的。
每个代理都需要配置该属性文件,而不仅仅是一个。
每次更改该文件后,都需要重新启动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。科达哈尔。韵律学