projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 9f82f66) | patch
splitter: 1.0.0-spring-ingetration - using a channel backed by Kafka spring-integration--dirty-hack-SubscribableKafkaChanel-as-input
authorKai Moritz <kai@juplo.de>
Sun, 17 Jul 2022 17:03:18 +0000 (19:03 +0200)
committerKai Moritz <kai@juplo.de>
Mon, 18 Jul 2022 16:37:42 +0000 (18:37 +0200)
commit6ed97946e9e3d4e94a6ec0cc05dc257f0558bae5
tree659a235998306fe079d7b2658c20c4287d72bdb2tree | snapshot
parent9f82f66f1a9ed3194889fee1b69a10287c4b03dbcommit | diff
splitter: 1.0.0-spring-ingetration - using a channel backed by Kafka

* Instead of the `@InboundChannelAdapter`, a `SubscribableKafkaChanel`
  could be used.
* But in the given setup, this is kind of a dirty hack, because with this
  konfiguration the intentionally read-only input-channel becomes writable
  in Spring Integration.
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.