projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: f58f069) | patch
coutner: 1.2.3 - Simplified topology, using default-serdes for all steps counter-1.2.3
authorKai Moritz <kai@juplo.de>
Fri, 17 Feb 2023 13:48:23 +0000 (14:48 +0100)
committerKai Moritz <kai@juplo.de>
Mon, 13 May 2024 18:31:56 +0000 (20:31 +0200)
commit386e87fd240741fac9e7f3e504b1284ecf3df7d8
tree79d7a3028be5a358a961efeadcff89203ef67f9dtree | snapshot
parentf58f069e556e9782656cf4e1d09eabbfcd6fa1c4commit | diff
coutner: 1.2.3 - Simplified topology, using default-serdes for all steps

- Defined `JsonSerde` as default for keys and values.
- Configured the `JsonDeserializer` for header-based typing.
- Removed the configuration of specific serdes from all steps of the
  processor-topology, expect the initial step, that needs a `StringSerde`
  for the key.
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationConfiguriation.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.