splitter: 1.1.2 - De-/Serialization are both using the default-serde
authorKai Moritz <kai@juplo.de>
Sun, 5 Feb 2023 11:18:18 +0000 (12:18 +0100)
committerKai Moritz <kai@juplo.de>
Sun, 5 Feb 2023 13:41:29 +0000 (14:41 +0100)
commitf132033a6793fc566962a4361d7d0a0e852b0f82
tree4857a82af36d13e47717c91ed9530af916142e35
parent5a5616b76c58e030a0529426d281548bdf1d835f
splitter: 1.1.2 - De-/Serialization are both using the default-serde

- Configured the default-serde for the expeced input and the intended output
- The configuration has to be supplied explicitly in the `Properties`,
  that are handed over during the instanciation of `KafkaStreams`.
- The `JsonDeserializer` needs the definition of a default-type for the
  value and position of trust for the class, that should be instanciated.
- The `JsonSerializer` should be advised to _not_ add the header
  `__TypeId__`, because it is not needed, if the topic only contains
  messages of a single type.
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java