So stellen Sie sich RetyrytopicNamesProvider mit Gruppen- oder ähnlichen Eigenschaften an ⇐ Java

[Anonymous]

Ich habe endlich gebrochen und dachte, ich würde sehen, ob jemand helfen könnte, wenn man einige ähnliche Gespräche an anderer Stelle berücksichtigt. Was keine Beispielantworten haben. Thema) im WiederholungsopicnamesProvider. Dies akzeptiert nur einen Themennamen, während alle anderen Methoden eine Methodensignatur von "Kafkalistenerendpoint" -Dendpunkt "haben.
Wenn dies verfügbar wäre@KafkaListener(topics = "#{config.![value.getIngressTopic()]}",
properties = {
"retryTopic:#{config.![value.getRetryTopic()]}",
"errorTopic:#{config.![value.getErrorTopic()]}"
},
< /code>
und verwenden Sie so etwas im ReturnicnamesProvider: < /p>
endpoint.getConsumerProperties()).getProperty("retryTopic")
< /code>
Unfeinst 'Endpoint' ist in GettopicName nicht vorhanden, was der ultimative Dekider des Wiederholungs- /Fehler -Themennamens ist. Ähnliches ähnliches auf Github https://github.com/spring-projects/spri ... sions/3339
Hilfe oder Zeiger werden geschätzt.