projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 1eada00) | patch
counter: Fixed a bug in the integration-test `CounterApplicationIT`
authorKai Moritz <kai@juplo.de>
Sat, 11 Feb 2023 14:26:42 +0000 (15:26 +0100)
committerKai Moritz <kai@juplo.de>
Sat, 11 Feb 2023 14:38:57 +0000 (15:38 +0100)
commit51280a23fb1d5bb04f1f071eb4720a3e8ec60e50
tree44196c1be9174e798783edc90718c7740203683etree | snapshot
parent1eada00db1c67936e7b5067a65a80207ce01f5f3commit | diff
counter: Fixed a bug in the integration-test `CounterApplicationIT`

- The default store-type creates state, that is stored on disk.
- Hence, only the first run of the test succseeded.
- The bug was fixed by providing an in-memory store-type.
src/main/java/de/juplo/kafka/wordcount/counter/CounterApplication.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.