从 KafkaStreams 输入流中获取记录并发送到两个输出流的最佳选择是什么？
What is the best option to take a record from a KafkaStreams input stream and send to two output streams?
在 Scala 中，我使用 import org.apache.kafka.streams.KafkaStreams 并且能够读取输入流并轻松地进行一些计算并发送到输出流。有没有办法通过 branch 或 filter 从输入流中获取结果记录并发送到 two 输出流？
branch 完全符合您的要求。它 returns 一个 KStream 数组，您可以单独发送 to() 两个不同的主题。
如果要将同一个流发送到两个主题，请使用 through 后跟 to
在 Scala 中，我使用 import org.apache.kafka.streams.KafkaStreams 并且能够读取输入流并轻松地进行一些计算并发送到输出流。有没有办法通过 branch 或 filter 从输入流中获取结果记录并发送到 two 输出流？
branch 完全符合您的要求。它 returns 一个 KStream 数组，您可以单独发送 to() 两个不同的主题。
如果要将同一个流发送到两个主题，请使用 through 后跟 to