projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 88bff95) | patch
Springify: Der Consumer kann unterschiedliche Nachrichten-Typen empfangen
authorKai Moritz <kai@juplo.de>
Sat, 28 May 2022 16:27:45 +0000 (18:27 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 5 Jun 2022 12:14:46 +0000 (14:14 +0200)
commit9fe455e4ccd0afdad0a9f12c009aa42151c2d098
tree5e09100ce504346cae36f33555a89041b0c31882tree | snapshot
parent88bff956053d9b21ba10d2655ad242118b4ae02dcommit | diff
Springify: Der Consumer kann unterschiedliche Nachrichten-Typen empfangen

* Neben `ClientMessage` gibt es jetzt auch noch den Nachrichten-Typ
  `Greeting`.
* `ClientMessage` ist auf den Bezeichner `message` gemapped.
* `Greeting` ist auf den Bezeichner `greeting` gemapped.
* Für die beiden bekannten Nachrichten-Typen sind via `@KafkaHandler`
  separate Handler konfiguriert.
* Unbekannte Nachrichten (z.B. `FooMessage`) landen zusammen mit anderen
  Fehlern in dem DLQ-Topic.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationHealthIndicator.java diff | blob | history
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
src/main/java/de/juplo/kafka/Greeting.java [new file with mode: 0644] blob
src/main/resources/application.yml diff | blob | history
src/test/java/de/juplo/kafka/ApplicationTests.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.