Как лучше всего взять запись из входного потока KafkaStreams и отправить в два выходных потока?

Question

В Scala я использую import org.apache.kafka.streams.KafkaStreams и могу считывать входной поток, легко выполнять некоторые вычисления и отправлять в выходной поток. Есть ли способ через branch или filter взять результирующую запись из входного потока и отправить в два выходных потока?

Answer 1

branch делает именно то, что вы хотите. Он возвращает массив KStream, который вы можете индивидуально отправить to() двумя разными темами.

Если вы хотите отправить один и тот же поток двум темам, используйте through, а затем to