Kafka Stream应用不转发事件有何影响？后续事件能否触发process调用？

1. Sink节点不转发当前事件的影响 #

首先明确Kafka Stream拓扑中两种场景的差异：

• 如果该节点是拓扑末端的原生Sink节点：本身设计就是将处理后的数据写入目标外部存储/主题，无下游后继节点，不存在转发逻辑，所以不做转发不会有任何异常影响，事件处理完成后offset会按配置规则正常提交，不会阻塞后续消息处理。
• 如果该节点是拓扑中间的自定义处理器（仅实现了类Sink的写入逻辑）：未调用context.forward()时，当前事件仅会执行该节点的自定义处理逻辑，不会向下游后继节点传递，下游节点无法收到该条事件，但不会影响整体流处理进度，offset仍会正常提交，不会出现流卡顿的情况。

2. AbstractProcessor的process方法触发规则 #

process方法的调用完全由输入主题的新事件拉取行为驱动，和上一条事件是否执行过转发逻辑没有关联：

• 只要消费线程正常拉取到输入主题的下一条事件，就会自动触发process方法执行。
• 唯一会中断后续调用的场景是：process方法抛出未捕获的未处理异常，触发了Kafka Stream的错误处理策略（比如默认的流实例关闭、跳过异常等配置规则）。

内容的提问来源于stack exchange，提问作者amitwdh