Spring-kafka和Apache-Kafka-Streams-Binder在与Kafka Stream API的交互方面有什么区别？

Question

我的理解是spring-kafka是为了与Kafka Client API交互而创建的，后来，spring-cloud-stream项目是为了“构建与共享消息系统连接的高度可扩展的事件驱动微服务”而创建的，该项目包括几个绑定器，其中一个是允许与Kafka Stream API交互的绑定器：

spring-cloud-stream-binder-kafka-streams

所以我很清楚，如果我想与Kafka流API交互，我将使用Spring-Cloud-Stream方法和适当的绑定器。

但是，我发现您可以使用spring-kafka方法与Kafka Stream API交互。
需要以下两个依赖项。这里有一个例子。

'org.springframework.kafka:spring-kafka'
'org.apache.kafka:kafka-streams'

所以我的问题是，如果这两种方法都允许与Kafka流API交互，那么这两种方法之间的区别是什么？

Answer 1

正如Gary在上面的评论中指出的，spring-kafka是较低级别的库，它为Spring Cloud Stream Kafka Streams绑定器（spring-cloud d-stream-binder-kafka-stream）提供了构建块。绑定器提供了一个编程模型，您可以使用它将Kafka Streams处理器编写为java.util.funciton.Funciton或java.util.function.消费者。您可以拥有多个这样的函数，并且每个函数都将构建自己的Kafka Streams拓扑。在幕后，绑定器使用Spring-Kafka使用StreamsBuilderFactoryBean构建Kafka StreamsStreamsBuilder对象。Binder还允许您组合各种函数。功能模型主要来自Spring Cloud Function，但它适用于绑定器实现中的Kafka Streams。简短的答案是spring-Kafka和Spring Cloud Stream Kafka Streams绑定器都可以工作，但绑定器提供了与Spring Cloud Stream一致的编程模型和额外功能，而spring-kafka提供了各种低级构建块。