1回答
我正在尝试在不使用Confluent Control Center的情况下执行此操作，因为我没有许可证。我可以使用dcos task metrics details <broker-id>查看Kafka Broker指标，并且可以看到所有这些指标都已经在我的DCOS Prometheus实例上公开了。然而，我在Prometheus上看不到任何消费者/生产者<e
浏览 24提问于2019-03-21得票数 0
我使用Strimzi操作符在Kubernetes上部署了一个带有消费者和生产者客户端的kafka集群。我使用了以下strimzi部署文件https://github.com/strimzi/strimzi-kafka-operator/blob/main/examples/metrics/kafka-metrics.yaml我正在使用Kafka exporter来监控</e
浏览 102提问于2021-07-20得票数 0
回答已采纳
我使用该框架在DC/OS集群中安装了Kafka。我想获取一些指标来监控它，我看到有这样的配置：我在代码中查看了一下，在server.properties.mustache中有一些配置参数：
浏览 4提问于2018-01-27得票数 0
我有多个Kafka消费者和生产者，有不同的主题。使用一个独立的应用程序，我想要监控kafka消费者的滞后。我正在使用kafka 0.10.0.1，因为Kafka现在将消费者偏移量存储在kafka本身中，所以我如何才能读取相同的偏移量。
我能够读取每个分区的主题偏移量。
浏览 0提问于2017-03-06得票数 0
到目前为止，我的设置是这样的: Spring -> Telegraf -> Kafka -> Telegraf -> influx我已经查看了测微器的配置，但没有为Kafka配置。由于Kafka是一个推送模型(即，您正在将数据推送到Kafka中)，Spring是否<
浏览 0提问于2019-02-12得票数 0
3回答
我只需要监控我的Kafka集群是否启动。运行Kafka的机器偶尔会关闭。如果群集不可用，我想发送电子邮件警报。
我可以创建一个生产者和消费者来定期发送和接收虚拟消息。有没有更简单的方法呢？
浏览 5提问于2021-07-20得票数 1
1回答
缺少Kafka生产者jmx指标
、、、、
我们有Spring Boot应用程序部署在开放源码开发环境( Kubernetes的原始社区发行版，支持Red )上。在没有经过devops团队太多调整的情况下，我们从kubernetes-service-endpoint exporter工作中获得了prometheus抓取的kafka消费者指标，以及一些生产者指标，但只针对kafka connect api，而不针对标准kafka生产者api。
浏览 1提问于2019-11-17得票数 1
它与Apache Kafka协同工作，有两个主要部分:生产者和消费者。
是否有可能在Cloudera Manager中监控所有正在运行的生产者和消费者(就像HDFS的DataNodes一样)？
浏览 0提问于2016-04-13得票数 1
1回答
Kafka主题的消费者监控数量
、、、、
我们使用Prometheus和Grafana来监控我们的Kafka集群。我们没有看到任何能够给出每个主题的活跃消费者数量的指标。我们是不是错过了什么？任何关于如何获取活跃消费者数量并在
浏览 16提问于2018-07-20得票数 2
回答已采纳
如果生产者一方的确认滞后很大，我们是否可以使用一些代理度量来监视Kafka broker。
我们正在使用datadog监控生产者和卡夫卡经纪人方面。可以看出，出厂延迟超过10秒。但是，在代理方面，我觉得只使用message.in.rate和kafka.net.bytes_in.rate并不是很有效。我们最好在代理端有一些滞后指标来指示the broker is fully loaded to acknowledge
浏览 1提问于2018-04-30得票数 6
回答已采纳
我在端口8081上的kafka代理上启用了JMX。当我在jConsole中查看MBean属性时，我只看到kafka.consumer的以下内容-
kafka.consumer:type=FetchRequestAndResponseMe
浏览 3提问于2016-06-14得票数 1
我正在尝试获取Apache Kafka健康指标，例如代理、生产者、消费者、Zookeeper、主题等指标，而不使用Confluent或任何其他软件/插件。我需要公开它们并将它们存储在Elasticsearch中。到目前为止还不能提取这些信息。关于如何从正在运行的Apache Kafka docker容器中提取此信息，有什么建议吗？
浏览 27提问于2019-01-17得票数 0
我有以下架构：我很困惑
1) whetherI can run kafka producer, broker and consumer on sepa
浏览 6提问于2015-11-02得票数 0
回答已采纳
我正在尝试设置Grafana仪表板来显示kafka指标。我正在尝试将kafka指标暴露给prometheus，这样Grafana仪表板就可以获取这些指标并进一步显示它们。org.apache.kafka:kafka-clients:jar:2.5.1:compile
io.micrometer:micrometer-registry-prometheus:jar:1.5.4management.endpoint.prometheus.enabled=t
浏览 7提问于2021-04-16得票数 0
我正在使用spring-integration来处理从UDP端点到kafka的数据流。我已经在@配置中使用消费者和生产者配置将replyingKafkaTemplate初始化为@Bean。当我的服务器启动并发送了一些udp请求后，我可以看到消费者的指标。但是，即使在生产者配置中设置了jmx报告器，我也看不到生产者的指标。我试着不设置生产者指标报告器，假设它会自动显
浏览 36提问于2019-04-30得票数 4
我正在使用Datadog从运行在我的本地主机上的Kafka收集指标。当我在我的Datadog代理上运行-info命令时，这是我为Kafka得到的错误。你知道这是什么原因吗？kafka - instance #kafka-localhost-9999 [ERROR]: 'Cannot connect to instance localhost
浏览 33提问于2016-08-27得票数 0
当我们想要横向规模的卡夫卡集群，我们可以这样做，增加更多的卡夫卡经纪人。我一直在努力理解，人们是如何决定“现在是向卡夫卡集群添加一个经纪人的时候了”？
有什么资源，我们可以用来监控卡夫卡经纪人的健康状况吗？
浏览 1提问于2021-08-30得票数 0
我们已经为高可用性和分布式数据负载设置了Kafka集群。当前的消费者和生产者指定所有代理IP地址以连接到集群。将来，将需要持续监控集群，并根据收集的指标和整体系统性能添加新的代理。在代理崩溃的情况下，我们必须尽快添加一个具有不同IP的新代理。
在这些情况下，我们必须更改所有客户端配置，这是一个既耗时又有压力的操作。我认为我们可以设置一个Config Server (例如Spring Cloud Config Server)，以集中方式指定所有代理IP地址，因此我们必须在
浏览 9提问于2021-09-19得票数 1
我正在设计和开发一个Kafka解决方案来读取Oracle表(Kafka Connect或CDC在我的组织中还不是一个选项)，并将这些大量的记录发送给Kafka Brokers，最终将被消费者收集并发送到目标系统我的卡夫卡生产者和消费者代码能在同一个Spring应用中吗？还是我需要让我的AppName-生产者和AppName-消费者作为两个单独的Spring应用程序，以便它们可以单独
浏览 3提问于2022-05-08得票数 1
kafka消费者正在从另一个主题中读取关于主题1中的数据处理是否成功或失败的信息，即主题2是否成功或失败。我正在启动我的消费者，然后将数据发布到主题1。.I想使生产者和消费者同步，即一旦生产者发布数据，消费者应该读取该数据的成功或失败消息，然后生产者应该继续处理下一组数据。
浏览 3提问于2017-08-01得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
