Kafka foreach 与进程

Question

我正在实现重建文件的逻辑，该文件分页到具有相同密钥的多个 kafka 消息。每次接收到一个页面时，其内容都会附加到共享卷中的相应文件中，并且一旦附加了最后一页，拓扑就必须包含一些额外的处理步骤。

1. 应该使用 forEach 还是使用 process？
2. forEach 和 process 都有 void 类型，那么如何将最后的额外步骤添加到拓扑中？

Answer 1

两者都实现了相同的目标。 foreach是DSL的终端动作，然而

process 处理器 API 的方法通过将数据转发到上下文将数据“返回”到下一个处理器，正如您在上一个问题中回答的那样，而不是通过处理方法本身