Производитель Kafka не может повторно подключиться к конвейеру при перезапуске ⇐ JAVA

[Anonymous]

Система находится на двух площадках, поэтому возникают проблемы с отказоустойчивостью, поэтому используется автоматический выключатель. Когда я нахожусь в состоянии закрытия, то при отправке сообщения на основной сайт при обратном вызове на вторичном сайте оба используют разные конвейеры Kafka. Когда по определенной проблеме на первичном сайте мы закрываем конвейер и переключаемся в открытое состояние и отправляем сообщение напрямую во вторичный конвейер. Автоматический выключатель снова переключается во включенное состояние, когда первичный Кафка становится исправным. При тестировании он перешел в открытое состояние, как и ожидалось, но когда наш основной сайт перезапустился и мы хотим вернуться в закрытое состояние, основной производитель не смог подключиться к конвейеру и начал выдавать исключение, и наш автоматический выключатель вернулся в открытое состояние.
Проблема — производитель не может отправить сообщение о перезапуске конвейера kafka.
версия
Kafka-clients — 0.11.0.0
Конвейер Kafka — 3.3.2
с использованием Java 8

Подробнее здесь: https://stackoverflow.com/questions/798 ... on-restart