projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 5c1e4e2) | patch
splitter: 1.0.0-spring-ingetration - extract the key on the inbound channel
authorKai Moritz <kai@juplo.de>
Mon, 18 Jul 2022 19:20:10 +0000 (21:20 +0200)
committerKai Moritz <kai@juplo.de>
Mon, 18 Jul 2022 19:45:58 +0000 (21:45 +0200)
commit26fd715128501924feb9c056f785db33e2ecbb71
treea8b81c8e94cb519d02bb957058eeea14a90f512ftree | snapshot
parent5c1e4e203c3c0d7c07b4ce1293a4a120faf1db3ccommit | diff
splitter: 1.0.0-spring-ingetration - extract the key on the inbound channel

* The key of the Kafka-Message is extracted on the inbound channel with
  a `HeaderEnricher`.
* This way, the key is propagated to dreived messages automatically.
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.