counter: 1.2.0 - Service reads/writes using `JsonSerde` counter-1.2.0
authorKai Moritz <kai@juplo.de>
Wed, 15 Feb 2023 07:19:09 +0000 (08:19 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 17 Feb 2023 16:33:18 +0000 (17:33 +0100)
commitc2d06f0efd9e09a9df1c4c536d54ad969cf456eb
tree8f6bb5b7eae00e82dcd0a880195591ff95a0e2c6
parentb02b75a4e70c41795a58ca38cd62d455af8aea16
counter: 1.2.0 - Service reads/writes using `JsonSerde`

- First working version of a refined topology, that reads and writes
  key and value with the `JsonSerde`.
- This topology expects and writes all data as JSON, except the key
  of the incomming messages.
- All used Serdes are directly configured in the topology.
pom.xml
src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java
src/main/java/de/juplo/kafka/wordcount/counter/Key.java [deleted file]
src/main/java/de/juplo/kafka/wordcount/counter/Word.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/wordcount/counter/WordCount.java [new file with mode: 0644]
src/test/java/de/juplo/kafka/wordcount/counter/TestData.java