如果 kafka stream 应用程序不转发事件会怎样?
What happens if kafka stream app don't forward event?
我想知道kafka stream sink note不转发current event会怎样?使用 AbstractProcessor
是否使用来自输入主题的下一个事件调用 process
方法?
如果未调用 forward
,则它在 Streams DSL 方法中的作用类似于 filter()
,即从拓扑中删除记录
我想知道kafka stream sink note不转发current event会怎样?使用 AbstractProcessor
是否使用来自输入主题的下一个事件调用 process
方法?
如果未调用 forward
,则它在 Streams DSL 方法中的作用类似于 filter()
,即从拓扑中删除记录