Как балансировать рассылку сообщений в Kafka на примере микросервисов на Nest.js?

Я создал приложение и несколько инстансов микросервиса Nest.js, которые взаимодействуют через Kafka.
Сейчас первый запущенный микросервис принимает сообщения, а второй и последующие копии - не получают сообщения.
Если я закрою первый микросервис, то спустя несколько секунд, сообщения начнёт получать тот, который подключился вторым.
Как мне разбалансировать рассылку сообщений, что б были задействованы все микросервисы? Пример с официально сайта Nest.js взял по взаимодействию с кафкой.


Ответы (0 шт):