projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: e3fc3fc) | patch
top10: 1.1.0 - Simplified topology, using JsonSerde
authorKai Moritz <kai@juplo.de>
Sun, 5 May 2024 12:55:17 +0000 (14:55 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 25 May 2024 14:55:33 +0000 (16:55 +0200)
commitdd840bb859d29f850fe6f69a00356b374fc4e209
treed19a9b85cd0f324840db5913be7efca579c0e31dtree | snapshot
parente3fc3fc028270a7faef487af51128771459aed20commit | diff
top10: 1.1.0 - Simplified topology, using JsonSerde

- Defined `JsonSerde` as default for keys and values.
- Removed the configuration of specific serdes from all steps of the
  processor-topology.
- Added type-mappings for serialization/deserialization.
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/wordcount/top10/Entry.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/top10/Key.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/top10/Ranking.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/top10/Top10ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/top10/Top10StreamProcessor.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.