Spring 带有 aws-kinesis 的云总线

Question

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

The Bus starters cover Rabbit and Kafka, because those are the two most common implementations, but Spring Cloud Stream is quite flexible and binder will work combined with 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。谁能指导我该怎么做？

Answer 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 带有 aws-kinesis 的云总线

Spring Cloud Bus with aws-kinesis

spring-cloud

spring-cloud-stream

spring-cloud-bus