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
authorKai Moritz <kai@juplo.de>
Sun, 17 Jul 2022 17:03:18 +0000 (19:03 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 17 Jul 2022 17:03:18 +0000 (19:03 +0200)
commitec42408f67d10a033fbb2320acfce091cfb8bf73
treefb0b81f41340d29bf46f2b64fe436b041eb20438tree | 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.