DLT auf Basis des `DeadLetterPublishingRecoverer` konfiguriert
authorKai Moritz <kai@juplo.de>
Sat, 10 Sep 2022 18:41:06 +0000 (20:41 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 11 Sep 2022 19:13:02 +0000 (21:13 +0200)
commitac154bb18a6c575fe01e70cba6a86d10580dfb89
treef39a9d26221d1afa28659ddb22950db6bd757cab
parent7a7926c1799495a3ed016cb1b204cbfe13f833f1
DLT auf Basis des `DeadLetterPublishingRecoverer` konfiguriert

* Der `DeadLetterPublishingRecoverer` muss explizit instanziiert werden.
* Um ihm den Spring-Kafka-Beans bekannt zu machen, muss die
  `DefaultErrorHandler`-Bean überschrieben werden.
* Der Recoverer wird dem Handler zusammen mit einer BackOff-Strategie
  übergeben.
* Damit der `DeadLetterPublishingRecoverer` die weiterzuleitenden
  Nachrichten senden kann, muss
* Der Producer benötigt scheinbar einen separaten Eintrag für
  `bootstrap-servers` unter `spring.kafka.producer`. Der Eintrag
  `spring.kafa.bootstrap-servers` wird hier nicht übernommen!
docker-compose.yml
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/resources/application.yml
src/test/java/de/juplo/kafka/GenericApplicationTests.java