Der Adder verarbeitet zwei Typen von JSON-Nachrichten anstatt String
authorKai Moritz <kai@juplo.de>
Sat, 3 Sep 2022 12:24:07 +0000 (14:24 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 4 Sep 2022 14:11:33 +0000 (16:11 +0200)
commit4e07958ca471036693e944b82b10567705ac55ed
tree26077cd6783ae86fbae5cf4f477154e0f3b7be9b
parent8fc65e4582c3c0f6ed5e1bb3cf20cea1d39b6f59
Der Adder verarbeitet zwei Typen von JSON-Nachrichten anstatt String

* Bisher waren alle Nachrichten vom Typ `String`.
* Jetzt verarbeitet der Adder zwei unterschiedliche Typen von Nachrichten.
* Die Nachrichten werden als JSON übertragen und mit Hilfe des
  `JsonDeserializer` von Spring Kafka in zwei unterschiedliche
  Spezialisierungen einer Basis-Klasse deserialisiert.
* Die für die Deserialisierung benötigte Typen-Information wird von dem
  Spring-Kafka-Tooling über den die `__TypeId__` transportiert.
* D.h., damit die Nachrichten korrekt deserialisiert werden können, ist es
  _nicht_ nötig, dass der Typ der Nachricht von Jackson aus der Nachricht
  selbst abgeleitet werden kann, sondern dass sich Sender und Empfänger
  darüber verständigen, welchen Hinweis sie in dem `__TypeId__`-Header
  hinterlegen.
pom.xml
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/ApplicationHealthIndicator.java
src/main/java/de/juplo/kafka/ApplicationRecordHandler.java
src/main/java/de/juplo/kafka/Message.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/MessageAddNumber.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/MessageCalculateSum.java [new file with mode: 0644]
src/test/java/de/juplo/kafka/ApplicationTests.java
src/test/java/de/juplo/kafka/MessageTest.java [new file with mode: 0644]