projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 89d429a) | 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>
Thu, 30 Jun 2022 18:13:36 +0000 (20:13 +0200)
commit723ec6bbc03aaa4f552fd3a27986c120ea46fccf
treede9b0581f599b57d64dbbf56ee312c45ff7a388etree | snapshot
parent89d429ad1ad583fb9d52d51ed37cd5a885a9c8c3commit | 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.