2

我有一个使用高级 Kafka Streams KStreamAPI 实现的流，并希望将两个连续的处理器附加到该流。

KStreamAPI 提供了一个process方法，但是该方法不返回任何内容，因此我假设它会改变拓扑。

在第一个处理器之后，我想附加第二个处理器，但我并不完全清楚我可以将下游处理器添加到哪个对象。

有任何想法吗？

4

0 回答 0