projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: e3fc3fc) | patch
top10: 1.1.0 - Simplified topology, using JsonSerde top10-1.1.0
authorKai Moritz <kai@juplo.de>
Sun, 5 May 2024 12:55:17 +0000 (14:55 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 30 May 2024 07:42:16 +0000 (09:42 +0200)
commit7e0f4ca6927d9b62909b0789b4b14a46f8dbd0f5
tree8329917c8a9d790f68f5f37faed1cc538d79b223tree | 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.