projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: c16e799) | patch
splitter: 1.0.0-spring-ingetration - fixed the ordering of the messages splitter-spring-integration
authorKai Moritz <kai@juplo.de>
Wed, 20 Jul 2022 19:02:42 +0000 (21:02 +0200)
committerKai Moritz <kai@juplo.de>
Wed, 20 Jul 2022 19:02:42 +0000 (21:02 +0200)
commitbc490d203bb6fbe99c397310d0aa1d3081390f03
treec40b6065ae218082146279dd85d3cab0b172b0f2tree | snapshot
parentc16e7996d992ad58b93c4fc344d81a890dc21489commit | diff
splitter: 1.0.0-spring-ingetration - fixed the ordering of the messages

* Added a `ChannelInterceptor` to the `KafkaSubscribableChannel`, that
  adds the value of the `key`-Header as Header `kafka_messageKey`).
* This fixes the ordering, because now, all words, that are split of from
  a recording of a user are send with the same key.
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.