Spring-Kafka 与 Spring-Cloud-Stream (Kafka)

Question

在微服务架构中使用 Kafka 作为消息系统 使用 spring-kafka 与 spring-cloud-stream + spring-cloud-starter-stream-kafka 有什么好处？

Spring Cloud Stream 框架支持更多的消息系统，因此具有更模块化的设计。但是功能呢？ spring-kafka 和 spring-cloud-stream + spring-cloud-starter-stream-kafka 的功能有差距吗？ 哪个 API 设计得更好？

期待阅读您的意见

Answer 1

带有 kafka binder 的 Spring Cloud Stream 依赖于 Spring-kafka。所以前者拥有后者支持的所有功能，但前者会更重量级。以下几点可以帮助您做出选择：

1. 如果您将来可能将 kafka 更改为另一个消息中间件，那么 Spring Cloud 流应该是您的选择，因为它隐藏了 kafka 的实现细节。
2. 如果你想将其他消息中间件与kafka集成，那么你应该选择Spring Cloud Stream，因为它的卖点是让这种集成变得容易。
3. 如果你想享受简单而不接受性能开销，那么选择 spring-kafka
4. 如果您计划迁移到 AWS Kensis、Azure EventHub 等公共云服务，请使用 Spring Cloud 系列中的 Spring Cloud Stream。

Answer 2

在创建系统时使用 Spring Cloud Stream，其中 one 通道用于输入进行一些处理并将其发送到 one 输出渠道。换句话说，它更像是一个 RPC 系统来代替 RESTful API 调用。

如果您打算做一个事件溯源系统，请使用 Spring-Kafka，您可以在其中发布和订阅相同的流。这是 Spring Cloud Stream 不允许您轻松完成的事情，因为它不允许以下操作

public interface EventStream {
    String STREAM = "event_stream";

    @Output(EventStream.STREAM)
    MessageChannel publisher();

    @Input(EventStream.STREAM)
    SubscribableChannel stream();
}

Spring Cloud Stream 可以帮助您避免做的一些事情是：

• 设置序列化器和反序列化器