【发布时间】:2021-09-03 10:14:30
【问题描述】:
我想知道如果kafka stream sink note不转发当前事件会发生什么?使用AbstractProcessor process 方法是否会被输入主题中的下一个事件调用?
【问题讨论】:
标签: java apache-kafka apache-kafka-streams
我想知道如果kafka stream sink note不转发当前事件会发生什么?使用AbstractProcessor process 方法是否会被输入主题中的下一个事件调用?
【问题讨论】:
标签: java apache-kafka apache-kafka-streams
如果 forward 没有被调用,那么它就像 Streams DSL 方法中的 filter() 一样,即从拓扑中删除记录
【讨论】: