用Kafka代替Spring Cloud巴士

jdgnovmf  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(255)

让我用一个例子来解释我的问题,
有一个叫做“通知服务”的微服务
它有两个示例在端口8080和8081上运行
我们的springcloud配置服务器也在运行,并且包含“notification service”的所有属性文件
当属性文件发生变化时,为了使其立即影响到所有正在运行的示例,我们可以使用spring云总线,

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

并使用postman工具一次刷新“notification service”的所有示例。
例如。,localhost:8080/bus/refresh
我想知道的是,有没有什么方法可以用Kafka而不是SpringCloudBus来做到这一点?

2w3kk1z5

2w3kk1z51#

也许你在找这个?

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

它被称为Spring Cloud流

相关问题