Использование Кафки вместо весеннего облачного автобуса

Question

Позвольте мне объяснить мою проблему на примере:

• Существует микро-сервис под названием «служба уведомлений»
• В нем есть 2 экземпляра, работающие в порте 8080 и 8081
• Наш сервер конфигурации Spring Cloud также запущен и содержит все файлы свойств «службы уведомлений»

Когда файл свойств изменяется, чтобы он немедленно вступил в силудля всех запущенных экземпляров мы можем использовать spring-cloud-bus,

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

и использовать инструмент почтальона для обновления всех экземпляров службы уведомлений одновременно.

• например, localhost: 8080 / bus / refresh

Что я хочу знать, есть ли способ сделать это, используя kafka вместо весенней облачной шины?

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