RetryTopicNamesProviderFactory с Spring-Kafka 3.0.10 ⇐ 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, но мне нужно изменить все имя, а не только суффикс, поэтому я не думаю, что это сработает.
Я реализовал неблокирующую повторную попытку для своего приложения 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, но мне нужно изменить все имя, а не только суффикс, поэтому я не думаю, что это сработает.
Мобильная версия