Kafka JMX度量的时间窗口是什么？
关于一些JMX度量的文档提到了一个时间窗口，在这个时间窗口上对一些度量进行平均。
例如：https://docs.confluent.io/current/kafka/monitoring.html
这个时间窗口是什么？是固定的、可配置的，还是动态调整的？
request-size-avg::
The average size of all requests in the window for a broker.
谢谢你的帮助。
共有1个答案
request-size-avg是从kafka-clients（生产者/消费者）计算的度量。该窗口可通过config配置:metrics.sample.window.ms
从正式文件来看：
The window of time a metrics sample is computed over.
默认情况下，此配置的值设置为30000（30秒）。此配置目前由消费者、生产者、Kafka Connect和Kafka Streams支持。
-
目前是否有一种方法可以将流量模式合并到OptaPlanner中并解决包装和交付VRP问题？ 比如说，我需要在30辆车中优化500辆今天和明天的提货和交付，其中每辆提货都有1-4小时的时间窗口。如果可能的话，我想在高峰时间避开城市的繁忙地区。 还可以添加（或同时取消）新的皮卡。 我相信这是一个常见的问题。OptaPlanner中是否有合适的解决方案？ 谢啦！
-
我很难让apache beam管道触发基于事件时间的触发器，但似乎能够随着处理时间触发窗口触发。 我的管道相当基本： > 我提取二级时间戳 我打开数据窗口进行处理 我按秒对数据进行分组，以便以后按秒对流数据进行分类。 我最终在分类的秒数上使用滑动窗口，有条件地每秒向pubsub发出两条消息中的一条。 我的问题似乎在步骤3中。 我试图在第3阶段使用与第5阶段相同的窗口策略，在分类秒数上运行滑动平均计
-
问题内容： 运行以下代码： 结果是： 上面的代码中没有定义任何窗口框架，它看起来默认的窗口框架是 不确定我对默认窗口框架的理解是否正确 问题答案： 从Spark Gotchas 默认帧规格取决于给定窗口定义的其他方面： 如果指定了ORDER BY子句，并且该函数接受了帧规范，则该帧规范是由RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW定义的， 否
-
我有一个关于Kafka流的时间窗的问题，有些概念真的让我困惑。 我们有一个主题每天获得1000万个事件，我们有6天的日志保留，所以总的主题包含6000万个事件。 现在，我创建了一个KTable，我正在执行load all操作并迭代事件。正如我之前提到的，实际上我们只是当前的事件，而不是6千万事件，所以我在KTable定义中窗口化了这些数据。 现在，当我用以下语句加载所有事件时，一切都运行良好。 问
-
我有数据流就像 事件名，事件id，Start_time（时间戳）... 在这里，我想对最后一个带有时间戳的字段<；code>；Start_。 因此，我在flink window中看到的是，所以我猜它需要过去30分钟的事件，但不考虑 我想把数据放在start_ time在最后30分钟内的位置，然后我如何编写转换？我是否需要使用该列使用？ 我是Flink的新手。 谢啦
-
问题内容： 我正在为Java游戏制作自己的自定义服务器软件（游戏和原始服务器软件都是用Java编写的）。没有可用的协议文档，因此我必须使用Wireshark读取数据包。 客户端连接时，服务器将以Gzip格式将其发送到级别文件。在发送大约94个数据包时，我的服务器通过ArrayIndexOutOfBoundsException使客户端崩溃。根据原始服务器的捕获文件，它大约在该点发送一个TCP窗口更新