projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: ad1f139) | patch
Springify: `start()`/`stop()`/`destroy()` in EndlessConsumer wiederbelebt
authorKai Moritz <kai@juplo.de>
Fri, 15 Apr 2022 08:56:40 +0000 (10:56 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 15 Apr 2022 11:56:25 +0000 (13:56 +0200)
commite446dd0b69167688f77bcc2a51fa551ab61916dc
tree9f48016694854334a04219fab0b65f34549b94e9tree | snapshot
parentad1f139b638e40e3c116ded9b5bfad911f0f00b8commit | diff
Springify: `start()`/`stop()`/`destroy()` in EndlessConsumer wiederbelebt

* Die Logik für Start/Stop liegt jetzt wieder wie vor der Umstellung in
  dem EndlessConsumer
* Der `ApplicationRunner` kenn den `EndlessConsumer` und ruft für diese
  `start()` auf
* Entsprechende Aufrufe im `DriverController` wiederbelebt.
* Das Stoppen beim Herunterfahren der App wird wieder über eine
  `@PreDestroy`-Methode im `EndlessConsumer` realisiert.
src/main/java/de/juplo/kafka/Application.java diff | blob | history
src/main/java/de/juplo/kafka/DriverController.java diff | blob | history
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.