Pring Cloud Config с шиной Kafka: Почему только один экземпляр получает обновление ⇐ JAVA

[Anonymous]

Я использую Spring Cloud Config Server с Kafka для трансляции события RefreshRemoteApplicationEvent всем экземплярам приложения, но в настоящее время его получает только один экземпляр. Моя установка включает в себя:
Репозиторий Spring Cloud Config
Сервер конфигурации со следующими зависимостями Maven:

Код: Выделить всё

org.springframework.cloud
spring-cloud-config-server


org.springframework.cloud
spring-cloud-config-monitor


org.springframework.boot
spring-boot-starter-actuator


org.springframework.cloud
spring-cloud-starter-bus-kafka


org.springframework.boot
spring-boot-starter-web

В свойствах моего приложения у меня есть Spring.cloud.bus.enabled=true и другие необходимые конфигурации.
Из моего Понимая это, проблема возникает потому, что все экземпляры находятся в одной потребительской группе Kafka. Когда я настраиваю каждый экземпляр с уникальной группой потребителей, все экземпляры будут отвечать событием AckRemoteRefreshEvent, но я не хочу управлять отдельными группами потребителей для каждого экземпляра, особенно при рассмотрении перезапуска приложений и повторной балансировки.
Я предполагал, что Spring Cloud Bus Kafka справится с этим сценарием «из коробки», позволяя всем экземплярам получать событие без необходимости использования нескольких групп потребителей. Есть ли какая-то конкретная конфигурация или настройка, которой мне не хватает для достижения такого поведения? Или есть лучший подход для этого сценария?
Будем очень признательны за любые советы и предложения!

Подробнее здесь: https://stackoverflow.com/questions/793 ... -refreshre