我正在实现重建一个文件的逻辑，该文件分页为具有相同密钥的多个kafka消息。每次收到页面时，其内容都会附加到共享卷中的相应文件中，并且一旦附加了最后一个页面，拓扑结构就必须包括一些额外的处理步骤。
- 这应该用forEach还是用过程来完成
- forEach和进程都有void类型，如何将最后的额外步骤添加到拓扑中
两者都实现了相同的目标。foreach是DSL的终端动作，然而
处理器API的CCD_ 2方法；返回"；通过将数据转发到上下文，而不是通过处理方法本身