1

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

Bus starters 涵盖了RabbitKafka,因为这是最常见的两种实现,但是 Spring Cloud Stream 非常灵活,并且 binder 可以与 spring-cloud-bus 结合使用。

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

4

1 回答 1

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>
于 2017-11-28T14:57:19.557 回答