带有 aws-kinesis 的 Spring Cloud Bus

Posted 2023-02-16

【中文标题】带有 aws-kinesis 的 Spring Cloud Bus

【英文标题】：Spring Cloud Bus with aws-kinesis

【发布时间】：2018-05-11 11:02:28

【问题描述】：

在Spring Cloud Bus (https://github.com/spring-cloud/spring-cloud-bus) 的文档中提到它像

The Bus starters 涵盖 Rabbit 和 Kafka，因为它们是两个 最常见的实现，但 Spring Cloud Stream 非常灵活 并且 binder 将与 spring-cloud-bus 结合使用。

在我的项目中，我们无法为 Rabbit 或 Kafka 维护另一个基础架构，因此我想将 spring-cloud-stream-binder-aws-kinesis (https://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis) 与 spring-cloud-bus 一起使用。谁能指导我该怎么做？

【问题讨论】：

包括 spring-cloud-bus 和 aws kinesis binder，你试过了吗？

@spencergibb 这就是我想做的，但我不确定如何包含 spring-cloud-bus 和 AWS kinesis binder。是否有任何指南或文档可以使用任何其他类似这样的 Spring Cloud Stream 实现来自定义 Spring Cloud Bus？？

看我的回答...

让我试试@ArtemBilan..thanks

明年某处。在 Spring Cloud AWS 2.0 和 Spring Cloud Stream 2.0 稳定之前，我们不会发布

【参考方案1】：

见https://github.com/spring-cloud/spring-cloud-bus/blob/master/spring-cloud-starter-bus-amqp/pom.xml:

<dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-bus</artifactId>
        </dependency>
</dependencies>

我想我们可以为 Kinesis Binder 采用相同的方式：

<dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-kinesis</artifactId>
            <version>1.1.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-bus</artifactId>
        </dependency>
</dependencies>

【讨论】：

是的，你需要spring-cloud-bus 和一个活页夹。