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>
Fri, 17 Feb 2023 17:06:41 +0000 (18:06 +0100)
commitcb4a5de56f142603eb63e82f6769616bf5ff058a
treef2ecbf3f5e9ee5c73577e1682f801ed4ee8470bdtree | 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.