Apache Kafka：处理器为每个输入生成多个输出

Question

我有一个 Kafka 流处理器，它必须将一个项目作为输入，并产生多个项目作为输出。 什么是正确的编码方式？多次致电this.context().forward(key, item) 是正确的做法吗？还是有其他作弊方式？

谢谢。

Answer 1

对于处理器 API，context.forward(key, item) 是正确的。

对于 DSL，您还可以使用 KStream#flatMapValues() 或 KStream()flatMap()。