java - Kafka Streams DSL 到处理器 API 之间有什么区别

Question

根据我从这里读到的内容: https://docs.confluent.io/3.0.0/streams/developer-guide.html#streams-developer-guide-processor-api

与我理解的不同之处在于，我可以在处理器 API 中更具体地了解哪些记录序列化程序进入流(源)到哪些退出流(接收器)，并且在流 DSL 中它必须相同。

是否可以使用 KStreamBuilder 和 TopologyBuilder 创建一个 Kstream，从而产生完全相同的流？ 如果可以的话我可以看一个例子吗？

Answer 1

... and in the stream DSL it must be the same.

我认为这是不对的。您可以从输入流中获取消息，更改值甚至键，然后将它们放在不同的输出流上。

final KStream<String, String> inputStream = builder.stream("inputStream");
...
inputStream
    .filter(this::acceptCertainMessages)
    .transform(new MyTransformerSupplier<String, String>("store"), "store")
    .to("outputStream");