projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 08ef2cb) | patch
splitter: 1.0.0-vanilla-kafka - Fixed the test "Context Loads"
authorKai Moritz <kai@juplo.de>
Sun, 26 Jun 2022 08:54:39 +0000 (10:54 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 26 Jun 2022 08:54:41 +0000 (10:54 +0200)
commit7a3d748f77f7eb2754dd1db63d087ebdd8b8a3e2
tree8f4dd6c9a635ee75b91f817c43b967b969017d90tree | snapshot
parent08ef2cb2e9bcef5a051eedd64da492baee6c1507commit | diff
splitter: 1.0.0-vanilla-kafka - Fixed the test "Context Loads"

* Added `spring-kafka-test` as dependency.
* Added `@EmbeddedKafka` to the integration test.
* Configured the test to support transactions (replication factor == 1).
* Fixed the `SplitterStreamProcessor`: the application logic is executed
  in a background thread, because it blocks the startup of Spring Boot
  otherwise.
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java diff | blob | history
src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.