projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 26fd715) | patch
splitter: 1.0.0-spring-ingetration - kafka-backed channels
authorKai Moritz <kai@juplo.de>
Mon, 18 Jul 2022 16:09:41 +0000 (18:09 +0200)
committerKai Moritz <kai@juplo.de>
Wed, 20 Jul 2022 18:36:53 +0000 (20:36 +0200)
commit8d0ef2423c0f6ef6a439b98a1d9b1b1a64d89d45
tree02d1a21e08b9653ff00e99d323d42b2e54afbf29tree | snapshot
parent26fd715128501924feb9c056f785db33e2ecbb71commit | diff
splitter: 1.0.0-spring-ingetration - kafka-backed channels

* This configuration uses `SubscribableKafkaChannel` to configure
  kafka-backed channels for the message-channels `recordings` and `words`.
* Since the header `kafka_messageKey` is not set, the messages are send
  with `null`-keys. Hence, the order of the messages will be lost for
  topics with more than one partition.
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.