У меня есть требование, согласно которому я хочу повторять попытки бесконечное количество раз (почему бесконечное количество раз, потому что я вызываю сторонний API от потребителя, и этот API может дать статус «ожидающий», а по данным стороннего поставщика они удерживают транзакцию в течение 2 дней и если транзакция все еще находится в ожидании, транзакция не состоится через 2 дня). Я хочу повторять попытки до тех пор, пока не получу неудачу, т. е. для меня это бесконечное количество раз.
Я решил переопределить значение по умолчанию для поля попыток аннотации RetryableTopic, чтобы, если я не упомяну попытки, тогда будут бесконечные попытки. срабатывать.
Я хочу расширить RetryableTopicAnnotationProcessor и переопределить методprocessAnnotation, чтобы установить максимальное количество попыток как Interger.Max_Value, когда мы получим значение по умолчанию 3.
Мой вопрос в том, что если я расширяю RetryableTopicAnnotationProcessor, то как мне зарегистрировать этот расширенный класс в качестве процессора по умолчанию для аннотации RetryableTopic?
Подробнее здесь: https://stackoverflow.com/questions/742 ... ring-kafka
Как переопределить значение по умолчанию 3 аннотации RetryableTopic в Spring Kafka ⇐ JAVA
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Python Kafka не видит заголовки/метаданные, в то время как Kafka UI и Kafka Go Lang делает
Anonymous » » в форуме Python - 0 Ответы
- 1 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Python Kafka не видит заголовки/метаданные, в то время как Kafka UI и Kafka Go Lang делает
Anonymous » » в форуме Python - 0 Ответы
- 0 Просмотры
-
Последнее сообщение Anonymous
-