Я наконец -то сломался и подумал, что увижу, если кто -нибудь смогу помочь, учитывая некоторые подобные разговоры в другом месте; которые нет примеров ответов. тема) в RetrytopicNamesProvider. Это принимает только имя темы, в то время как у всех других методов есть подпись метода «kafkalistenerendpoint endpoint».@KafkaListener(topics = "#{config.![value.getIngressTopic()]}",
properties = {
"retryTopic:#{config.![value.getRetryTopic()]}",
"errorTopic:#{config.![value.getErrorTopic()]}"
},
< /code>
И используйте что -то подобное в RetrytopicNamesProvider: < /p>
endpoint.getConsumerProperties()).getProperty("retryTopic")
< /code>
Невыносительно 'Endpoint' не присутствует в GetTopicName, который является окончательным решающим департаментом темы Retry /ошибки. < /p>
Gary Russel Дополнение кто-то спросил что-то подобное на github https://github.com/spring-projects/spri ... 39образное>
Подробнее здесь: https://stackoverflow.com/questions/797 ... properties
