使用 Kafka 代替 Spring Cloud Bus

Question

让我用一个例子来解释我的问题，

• 有一个叫做“通知服务”的微服务
• 它有 2 个实例在端口 8080 和 8081 中运行
• 我们的 Spring 云配置服务器 也在运行并包含所有 “通知服务”的属性文件

当属性文件发生变化时，为了让所有正在运行的实例立即生效，我们可以使用spring-cloud-bus，

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    </dependency>

并使用邮递员工具一次刷新“通知服务”的所有实例。

• 例如，localhost:8080/bus/refresh

我想知道的是有没有办法使用kafka而不是spring cloud bus来做到这一点？

Answer 1

也许你正在寻找这个？

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-kafka</artifactId>
    <version>2.1.0.RELEASE</version>
</dependency>

它被称为Spring Cloud Stream