projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0648885) | patch
query: 2.0.0 - Defined 2 state-stores (all state in-memory in tests)
authorKai Moritz <kai@juplo.de>
Wed, 12 Jun 2024 20:46:24 +0000 (22:46 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 13 Jun 2024 15:28:59 +0000 (17:28 +0200)
commitfc5d6c6ee08a4b2e29a045bf4071dd0a4d86bc0d
treeb72f5164de652227fbe983206767e52b56f9c1c2tree | snapshot
parent0648885ec026d7434561060dc7edb703efea6853commit | diff
query: 2.0.0 - Defined 2 state-stores (all state in-memory in tests)

* Introduced a second state-store to store the incomming users-table.
* Without the explicit definition of the state-store, it is _not_ possible,
  to reconfigure the integration-test in such a way, taht it does not
  store its state locally on disk.
src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/query/QueryApplicationIT.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/query/QueryStreamProcessorTopologyTest.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.