projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0e63376) | patch
splitter: 1.0.0-spring-integration - Inital implementation (incomplete)
authorKai Moritz <kai@juplo.de>
Sun, 26 Jun 2022 12:05:11 +0000 (14:05 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 30 Jun 2022 18:43:18 +0000 (20:43 +0200)
commit9c9ffbe3316ed295533c576e823794aa6de99665
treed650528f3423e4dd1dba1c17a44e05f718207dc3tree | snapshot
parent0e63376a3cfc8ecabdc4699e9307f6a51415cb09commit | diff
splitter: 1.0.0-spring-integration - Inital implementation (incomplete)

* "Implementing" the splitter with Spring Integration mainly is a
  configuration task.
* This version does not yet send the messages with the correct key.
* Managment of transactions is not yet considered.
* The test fails, because the key is missing.
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/wordcount/splitter/MessageSplitter.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationProperties.java diff | blob | history
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java [deleted file] blob | history
src/main/resources/application.properties 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.