projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 316c89a) | patch
`EndlessConsumer` auf `@KafkaHandler` umgestellt
authorKai Moritz <kai@juplo.de>
Sat, 10 Sep 2022 16:04:04 +0000 (18:04 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 11 Sep 2022 14:42:49 +0000 (16:42 +0200)
commit0c9a0c1cf9a0065012743efcd940d8721bc33c20
treebff8fbb42a222128232c01fb48b0cca40f2ddb3etree | snapshot
parent316c89aa6aafbc339eda3727638c75f5489c0a99commit | diff
`EndlessConsumer` auf `@KafkaHandler` umgestellt

* Mit `@KafkaHandler` können separate Handler-Methoden für die
  unterschiedlichen Nachrichten-Typen definiert werden, die die
  Anwendung empfängt (hier: über ein Topic, auch mögich: über
  verschiedene Topics).
* Die Tests mussten an die geänderte Implementierung angepasst werden.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationHealthIndicator.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationRecordHandler.java diff | blob | history
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
src/main/java/de/juplo/kafka/RecordHandler.java diff | blob | history
src/test/java/de/juplo/kafka/GenericApplicationTests.java diff | blob | history
src/test/java/de/juplo/kafka/TestRecordHandler.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.