Kafka流程序正在重新处理已处理的事件
我将一些事件转发给Kafka并启动了我的Kafka流程序。我的程序开始处理事件并完成。一段时间后，我停止了我的Kafka流应用程序并重新开始。观察到我的Kafka流程序正在处理已经处理过的先前事件。
根据我的理解，Kafka流在内部维护每个应用程序id的输入主题本身的偏移量。但在这里重新处理已经处理的事件。
如何验证Kafka流处理的偏移量？Kafka流是如何保存这些书签的？根据什么
如果Kafka蒸汽抛出异常，那么它是否重新处理了已经处理的事件？
请澄清我的疑问。
请帮助我理解更多。
共有1个答案
Kafka Streams在内部使用Kafka消费者，所有正在运行的实例都使用application.id作为group.id形成一个消费者组。偏移量定期提交到Kafka集群（可配置）。因此，在以相同的application.id重新启动时，Kafka Streams应该会拾取最新提交的偏移量并从那里继续处理。
您可以使用bin/kafka消费群体检查任何其他消费群体的已提交补偿。sh工具。
-
我们正在应用程序中使用apache kafka streams 0.10.2.0。我们利用kafka streams拓扑将处理后的数据传递到下一个主题，直到处理结束。 此外，我们使用AWS ECS容器来部署消费者应用程序。我们观察到消费者正在拾取非常旧的消息进行处理，尽管它们已经在更早的时候处理过。这个问题在服务扩展/缩减或新部署时随机发生。我知道在消费者重新平衡时，有些消息可以重新处理。但在这种
-
事件就是用户或浏览器自身执行的某种动作。诸如click、load 和mouseover，都是事件的名字。而响应某个事件的函数就叫做事件处理程序（或事件侦听器）。事件处理程序的名字以"on"开头，因此click 事件的事件处理程序就是onclick，load 事件的事件处理程序就是onload。为事件指定处理程序的方式有好几种。 13.2.1 HTML事件处理程序某个元素支持的每种事件，都可以使用一
-
事件 事件，就是文档与浏览器发生特定的 交互瞬间。JavaScript与HTML之间的交互就是通过事件实现的。 事件流 所谓事件流，就是接收页面事件的顺序。 事件流分 事件冒泡流 与 事件捕获流。事件冒泡流是IE开发团队提出的，捕获流是Netscape开发团队提出的。 事件冒泡流 所谓事件冒泡，就是事件开始时由 最具体的元素（文档中嵌套最深的那个 节点）接收，然后逐级向上传播到较为不具体的节点（文
-
本文向大家介绍学习JavaScript事件流和事件处理程序，包括了学习JavaScript事件流和事件处理程序的使用技巧和注意事项，需要的朋友参考一下 本文全篇介绍了JavaScript事件流和事件处理程序，分享给大家供大家参考，具体内容如下 一、事件流 事件流描述的是从页面中接收事件的顺序。IE的事件流是事件冒泡流，而Netscape Communicator的事件流是事件捕获流。 二、事件冒泡
-
具有Kafka Streams应用，其通过例如1天的流连接来执行开窗(使用原始事件时间，而不是挂钟时间)。 如果启动此拓扑，并从头开始重新处理数据（如在 lambda 样式的体系结构中），此窗口是否会将旧数据保留在那里？da 例如：如果今天是2022-01-09，而我收到来自2021-03-01的数据，那么这个旧数据会进入表格，还是会从一开始就被拒绝？ 在这种情况下，可以采取什么策略来重新处理这些
-
问题内容： 任何人都可以澄清一下下面的过程是否是正确的处理流程流的方法，而没有任何流缓冲区已满和阻塞问题 我正在从Java程序中调用外部程序，正在使用ProcessBuilder来构建流程，执行之后 我正在使用一种方法来处理流程 在我的方法中，我试图处理流程流 readStream方法用于读取我的流文本。 问题答案： 不，那不是正确的方法。 首先，在某些系统上，您的代码将永远停留在调用中，因为该过