阿帕奇卡夫卡：處理器生成每個輸入

Question

多輸出我有一個具有把一個項目作爲輸入卡夫卡流處理器，和產生多個項作爲輸出。 什麼是正確的編碼方式？多次撥打電話this.context().forward(key, item)是正確的做法，還是有另一個作弊？

謝謝。

Answer 1

用於處理器API，context.forward(key, item)是正確的。

對於DSL，你也可以使用KStream#flatMapValues()或KStream()flatMap()。