«Исключение аутентификации/авторизации и отсутствие AuthexceptionRetryInterval Set» в Spring Kafka против Cloud Kafka ⇐ JAVA

[Anonymous]

Я работаю над двумя пружинными микросервисами, развернутыми на AWS-EKS, и использую Kafka, где MS1 использует Spring Kafka, а MS2 использует облачную кафку. В обоих случаях, если я обновлю политику авторизации темы (политика IAM-MSK), оба бросят < /p>

proberg.springframework.kafka.listener.kafkamessagelistenercontainer:
Authentrication /Authorization Exception и no
authexceptionretrevertener: < /> protectorization /authorization exception> wortexceptionretr />
орг.springframework.kafka.listener.kafkamessagelistenercontainer:
Fatal Consumer Exception; остановка контейнера < /p>
< /blockquote>
Ошибки. Я хотел, чтобы мои микросервисы продолжали работать, повторяя соединение кафки в определенном интервале, а не останавливая контейнер. Для MS1, когда я добавил исправление, добавив Custom Bean для concurrentKafkalistenerContainerFactory и используя conturentkafkalistenercontainerfactory.getContainerProperties (). SetAuthexceptionretryInterval () Метод в нем начал работать, как и ожидалось. Но для Cloud Kafka проблема сохраняется с вышеупомянутым исправлением. Я попытался установить значение Spring.cloud.stream.BindingreTryInterval , с которым он частично работал (если политика неверна, когда POD начинается), но в другом случае не удалось (когда POD работает, а затем политика повреждена). Какова правильная конфигурация мне нужно применить в моем приложении YAML или какой код мне нужно применить, чтобы MS2 никогда не останавливал контейнер, а повторил соединение в определенном интервале, например, исправление MS1.

Подробнее здесь: https://stackoverflow.com/questions/796 ... rval-set-i