RetryTopicNamesProviderFactory с Spring-Kafka 3.0.10JAVA

Программисты JAVA общаются здесь
Ответить
Гость
 RetryTopicNamesProviderFactory с Spring-Kafka 3.0.10

Сообщение Гость »


Я реализовал неблокирующую повторную попытку для своего приложения Kafka, используя Spring-Kafa 2.7. Мне нужно было собственное имя темы для DLT, поэтому я использовал RetryTopicNamesProviderFactory. В этой версии процесс повторной попытки работал должным образом. Недавно приложение было перенесено на Spring Kafka 3.0.10, и теперь используется DLT по умолчанию. Похоже, что RetryTopicNamesProviderFactory теперь игнорируется. Я нашел сообщение, в котором утверждается, что: В версии 2.9.x и выше конфигурация bean-компонента RetryTopicNamesProviderFactory больше не поддерживается. Существует ли эквивалентный или альтернативный метод настройки собственного имени DLT для повторяемой темы с использованием Spring-Kafka 3.0.10? Я посмотрел RetryTopicConfigurer, но мне нужно изменить все имя, а не только суффикс, поэтому я не думаю, что это сработает.
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»