Apache Kafka：プロセッサは入力ごとに複数の出力を生成します

Question

私は入力として1つのアイテムを取らなければならないカフカストリームプロセッサを持っており、出力として複数のアイテムを生成します。 コードを作成する正しい方法は何ですか？ this.context().forward(key, item)への複数回の呼び出しが正しい方法ですか、別の不正行為がありますか？

ありがとうございました。

Answer 1

プロセッサAPIの場合はcontext.forward(key, item)が正しいです。

DSLでは、KStream#flatMapValues()またはKStream()flatMap()を使用することもできます。