Kafka JMX度量当前消息速率
我已经在本地启动了Kafka代理实例，jmx_prometheus_javaagent作为java代理。
为了尝试我的设置，我使用一个简单的Kafka制作者向本地Kafka代理发送非常小的消息，该制作者能够在不到5秒内发送100万条消息，然后停止。在这个实验中，我希望看到5秒的平均速率出现峰值，然后再回到0。
问题
普罗米修斯曲线图中反映的情况如下：-
普罗米修斯配置：-
- pattern : kafka.server<type=(.+), name=(.+)PerSec\w*, topic=(.+)><>MeanRate
name: kafka_server_$1_$2_mean_rate
labels:
topic: "$3"
普罗米修斯查询-floor（Kafka•服务器•经纪人度量指标•消息平均速率）
什么是正确的方法/prometheus query/mbean来获得消息传入的准确率？
共有1个答案
您应该使用Count，并在Prometheus一侧获取它的的速率（）。JMX导出程序附带的示例配置文件已经为您选择了正确的指标。
MeanRate是二进制文件启动后每秒的平均速率，因此它不是很有用。一分钟、五分钟和五分钟是指数移动平均数，因此也会随时间衰减。
https://www.youtube.com/watch?v=67Ulrq6DxwA有关于不同仪器/监控系统处理计数器的各种方式的更多信息。
-
在我当前的Azure IoT中心解决方案中，我使用D2C/C2D消息、设备双胞胎和文件上传。我看了一下我每天的总计量消息（），有点惊讶，因为数字比预期的要高（每天10k）。 然后我看了看我的d2c/c2d消息（每天约100-350） 我的设备twin从设备读/写（每天约500次） 我的文件上传（每天约4k） 使用的查询： 我现在的假设是： 我的假设正确吗 是否有内置功能允许我查看按消息类型（d2c
-
我的代码仍在工作，我可以发送消息并等待消息发送完毕。发送消息的持续时间大约为10秒，这对我不好，因为我的程序需要1秒的间隔才能发送下一条消息。看看以澄清问题。 msg4- msg4、msg3和msg2仍在等待，直到msg1发送/失败。 这是代码sendMessage.java 在我看来。java类 第一条消息已成功发送，但第二条消息等未发送。如何使这些等待直到发送第一条消息？
-
问题内容： 我目前正在尝试使用JavaMail从IMAP服务器（Gmail和其他服务器）获取电子邮件。基本上，我的代码有效：我确实可以获取标头，正文内容等。我的问题如下：在IMAP服务器（无SSL）上工作时，基本上需要1-2毫秒来处理一条消息。当我使用IMAPS服务器（因此使用SSL，例如Gmail）时，我达到了大约250m /消息。我仅测量处理消息时的时间（不考虑连接，握手等）。 我知道由于这是
-
从Queue获取计数的旧方法是这样的： 这不再适用于. netCore和AMQP 1.0 我没有找到一个好的方法来获得消息计数。知道我错过了什么吗？
-
我对SQS非常陌生，如果我忽略了一些显而易见的事情，我很抱歉，但是有没有办法获取SQS中消息的当前可见性超时？我可以在这里看到如何更新超时可见性。但是我没有看到任何关于获取消息当前可见性超时的信息（也许你可以在收到消息时查看）。 我的用例是根据给定消息的当前可见性超时更改可见性超时。这可能吗？ （注意：我知道我可以使用近似的接收时间来达到类似的效果，如果不可能获得当前可见性时间，我会走那条路）
-
我正在尝试配置一个rsyslog服务器来接收来自docker容器的日志。我目前正在使用以下突击队来运行docker容器： 我使用rfc5424，因为从docker到rsyslog的标准日志格式在冒号字符处中断消息，拆分标记remote：shouldshow并将shouldshow添加到消息中。有关此情况的更多信息，请参见：https://github.com/docker/docker/issue