projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: e8eee1b) | patch
splitter: 1.1.0 - Input/Output is expected/read as JSON splitter-1.1.0
authorKai Moritz <kai@juplo.de>
Sat, 4 Feb 2023 10:13:50 +0000 (11:13 +0100)
committerKai Moritz <kai@juplo.de>
Sun, 5 Feb 2023 13:41:17 +0000 (14:41 +0100)
commitcbabb637d0332ef3d8c67faf63e6e6897a69977f
tree8c452a31d765d38643bd979e60dbe0e6132a897dtree | snapshot
parente8eee1b8a20b4aeadcb5384dd8473bc8a543a259commit | diff
splitter: 1.1.0 - Input/Output is expected/read as JSON

- The input is mapped to the class `Recording`
- The output is mapped as class `Word`
- Added a test, that asserts, that the expected input can be read and the
  intended output is written.
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/wordcount/splitter/Recording.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/splitter/Word.java [new file with mode: 0644] blob
src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationTests.java [new file with mode: 0644] blob
Unnamed repository; edit this file 'description' to name the repository.