1回答
有没有办法使用Metrics java API从kafka.network:type=RequestMetrics,name=TotalTimeMs,request={Produce|FetchConsumer|FetchFollower}获取请求的总时间？使用下面的代码，我能够获得生产者度量。 for (Entry<MetricName, ?+ " : " + entry.getValue().metricValue());
} 但我不确定如何获得TotalTimeMs
浏览 16提问于2019-05-12得票数 1
我正在尝试配置prometheus服务监视器来获取合流云(Kafka)指标。根据他们的文档()，他们已经使用scrape_config进行了配置。kind: Servicemetadata: namespace: monitoringlabels:
app: kafka-metr
浏览 6提问于2022-06-13得票数 1
1回答
我知道Kafka API中可用于生产者指标的metric()方法。实际上，我正在尝试通过以下方式定期获取10k条记录、100k条记录等的指标： ? 我从Intellij IDE运行我的制作器，它将产生大约一百万条记录。我尝试用以下方式打印指标： for (Entry<MetricName, ?extends Metric> entry : producer.metrics().entrySet()) {
Sy
浏览 15提问于2019-05-08得票数 2
回答已采纳
我正在尝试将Kafka主题滞后引入Prometheus，并最终进入APIServer，以便在我的应用程序中使用外部度量HPA。
我得到错误没有从外部指标API返回的指标。kafka_lag_metric_sm0ke: unable to get external metric default/kafka_lag_metric_sm0ke/&LabelSe
浏览 3提问于2021-04-18得票数 2
回答已采纳
我正在编写一个Flink应用程序，它使用kafka主题中的时间序列数据。时间序列数据包含指标名称、标记键值对、时间戳和值等组件。下面是主流看起来像 kafka source -> Flat Map which parses and emits Metric -> Key by metric
key -> Tumbling window我正在考虑使用flink的"allowedLateness“功能将延迟
浏览 17提问于2021-08-09得票数 0
回答已采纳
1回答
Kafka生产者指标
、、、
我正在使用我的Intellij IDE在本地机器上运行一个Kafka生成器&该生成器将产生一百万条记录。在执行此操作时，我希望通过以下方式捕获生产者指标： ? 我知道kafka的JMX端口&我确实尝试过将Kafka JMX端口设置为9999。但我不确定我们是否可以像我期望的那样使用JConsole或JVisualVM获得指标。
浏览 23提问于2019-05-07得票数 3
回答已采纳
为什么在度量报告中有两个不同的属性？是什么让他们与众不同？
谢谢你，艾比
浏览 0提问于2019-01-28得票数 3
回答已采纳
我正在尝试导出kafka连接指标。我的解决方案包括运行jmx导出器并在端点公开它们，然后可以使用Prometheus抓取该端点。现在，我可以对我尝试过的所有指标执行此操作，但对于一组指标，它不起作用。我对这组指标的导出配置如下所示 name: <em
浏览 18提问于2020-05-26得票数 1
我正在尝试在Java中获取主题级别的Kafka指标。显示我可以使用JMX获取它们，但我不确定如何做到这一点。文档将MBean显示为kafka.producer:type=producer-topic-metrics,client-id="{client-id}",topic="{topic}"我不确定将实际的指标名称放在哪里\""
我也不确定如何实际使用bean，以及在哪里指定kafka集群信
浏览 2提问于2019-04-26得票数 2
我正在使用Springboot 2运行Kafka Stream应用程序。我想在host:8080/actuator/prometheus上以普罗米修斯格式提供我的卡夫卡数据流指标 我没办法拥有这个。我不确定我是否理解kafka流指标是如何导出的。actuator可以获得这些JMX指标吗？有没有办法获得这些指标并以普罗米修斯格式公开它们？ PS:也没有使用java jmx_prometheus_agent 有人有解决
浏览 46提问于2019-09-25得票数 7
我们想要得到Kafka消费者群体指标(例如节流和字节率)。我们已经这样做了，使用： bin/kafka-使用者-groups.sh-描述-组group_name -引导-服务器本地主机到目前为止，我们已经尝试过也被bin/kafka bin/kafka-s
浏览 2提问于2019-12-04得票数 0
我有一个闪光作业，处理Metric(name, type, timestamp, value)对象。指标是keyby (名称、类型、时间戳)。我正在尝试使用启动timestamp + 50 second的特定timestamp来处理指标。每个时间戳的间隔为10秒。我目前正在尝试使用ProcessWindowFunction的window(SlidingEventTimeWindows.of(Time.seconds(50), Time.seconds(
浏览 17提问于2021-07-24得票数 0
回答已采纳
1回答
我试图使用python中的kafka主题，并使用prometheus客户端在http上服务，但是我似乎在主题消耗上被阻止了。我让一些位置持有者简单地添加度量标准，但这部分似乎被屏蔽了。def collect(self): topic= client.topics[b'os.environ['KAFKA_TO
浏览 1提问于2018-05-28得票数 1
回答已采纳
我在让Kafka Connect向Graphite发送指标：kafka.consumer:*和kafka.connect:*时遇到了麻烦。列表在这里：{
"metric.reporters":
浏览 6提问于2019-07-18得票数 0
我试图收集卡夫卡的消费者和生产者的指标使用千分尺与Springboot。但在千分尺图书馆里找不到这类人。消费者财产是：但是，由于io.micrometer.core.instrument.binder.kafka.
浏览 12提问于2020-01-11得票数 1
我无法为Confluent connect服务导出"type=connector- metrics“指标，但其他指标运行良好。我正在使用prometheus exporter java代理从Confluent connect公开指标，如下所示。-0.12.0.jar=8093:/opt/prometheus/kafka-connect.yml‘ kafka-connect.yml - pattern: kafka.conne
浏览 30提问于2020-07-15得票数 0
当前有一个并发消息侦听器容器设置，它将报告所使用的每个消息的度量。 由于某些原因，某些指标会多次报告，我不确定why.maybe这是spring-kafka的问题，而不是kafka本身的问题？extends Metric>> metrics = messageListenerContainer.metrics();
metrics.forEach( (clientid, metricMapSystem.ou
浏览 33提问于2019-10-19得票数 0
我正在尝试通过producer.metrics()接口调用获取kafka producer的所有指标。我的尝试是：但是我只能看到记录发送速率的值，但是我找不到记录发送总数。extends Metric</e
浏览 13提问于2019-07-30得票数 0
2回答
我创建了一个实现org.apache.kafka.common.metrics.KafkaMetric的类，如下所示： System.out.println(metric.metricName().name() + ": " + metric.value() + " tags: " + metric.metricNamepublic void close(
浏览 0提问于2018-09-07得票数 1
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号