projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: e1ec32b) | patch
counter: 1.1.11 - Added a test, that is based on `TopologyTestDriver` counter-1.1.11
authorKai Moritz <kai@juplo.de>
Sat, 11 Feb 2023 12:02:44 +0000 (13:02 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 17 Feb 2023 16:33:10 +0000 (17:33 +0100)
commitb02b75a4e70c41795a58ca38cd62d455af8aea16
treeda3fbe7813b9187f692a7ac71527b0269e24d1fctree | snapshot
parente1ec32bcc70e5f990ca2ddb5566f98cee7e4c2c2commit | diff
counter: 1.1.11 - Added a test, that is based on `TopologyTestDriver`

- The test reuses `TestData` to asserts the exact same assumptions, as
  `CounterApplicationIT`.
- The only difference is, that the message processing is carried out by
  the `ToplogyTestDriver` instead of a real Kafka cluster, that is started
  along the test-code in the same JVM, as in `CounterApplicationIT`.
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessorTopologyTest.java [new file with mode: 0644] blob
Unnamed repository; edit this file 'description' to name the repository.