projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: dc7be5b) | patch
popular: 1.3.0 - Refined output JSON
authorKai Moritz <kai@juplo.de>
Sat, 22 Jun 2024 11:15:06 +0000 (13:15 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 22 Jun 2024 11:15:06 +0000 (13:15 +0200)
commit37c78ce13c2c8b6653704177bd4284e8aed94166
treeae9f2e29c188d066d6d6ec0309440986acaa8c37tree | snapshot
parentdc7be5b9ac6d8b441039f8503b61652e74f4faeecommit | diff
popular: 1.3.0 - Refined output JSON

* Added attribute `type` with fixed value `POPULAR`.
* Renamed attribute `time` to `channel`.
* Adapted test-cases accordingly.
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/popular/WindowedWord.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/popular/TestData.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/stats/OutputWindowedWord.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.