juplo.de Git - demos/kafka/training/commit

]> juplo.de Git - demos/kafka/training/commit

projects / demos / kafka / training / commit

author	Kai Moritz <kai@juplo.de>
	Sat, 28 May 2022 16:27:45 +0000 (18:27 +0200)
committer	Kai Moritz <kai@juplo.de>
	Sun, 5 Jun 2022 12:14:46 +0000 (14:14 +0200)
commit	9fe455e4ccd0afdad0a9f12c009aa42151c2d098
tree	5e09100ce504346cae36f33555a89041b0c31882	tree \| snapshot
parent	88bff956053d9b21ba10d2655ad242118b4ae02d	commit \| 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.

Unnamed repository; edit this file 'description' to name the repository.

RSS Atom

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