projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 9c9ffbe) | patch
splitter: 1.0.0-spring-integration - Added the key of the incoming message
authorKai Moritz <kai@juplo.de>
Sun, 26 Jun 2022 16:07:32 +0000 (18:07 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 30 Jun 2022 19:33:38 +0000 (21:33 +0200)
commit7b017bc9954ecf26af755d43dd02999468cd94ea
tree98bb747bec52b0ec327b979ef492e3c32140667ftree | snapshot
parent9c9ffbe3316ed295533c576e823794aa6de99665commit | diff
splitter: 1.0.0-spring-integration - Added the key of the incoming message

* Added a `ChannelInterceptor`, that copies the key from the received
  message to the outgoing message.
* This fixes the test.
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.