projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: fc682d9) | patch
refactor: Alle Kafka-Belange in den `WordcountRebalanceListener` verschoben
authorKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 10:04:27 +0000 (12:04 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 14:45:21 +0000 (16:45 +0200)
commit9511a89368c96d0b5f09d55adaaed5515c578dcc
treeb745617636da7444358d5e4b674a0d9540efdc36tree | snapshot
parentfc682d9890787ef363b3e189f6f880a043f3c541commit | diff
refactor: Alle Kafka-Belange in den `WordcountRebalanceListener` verschoben

* Dafür neues Interface `PollIntervalAwareRebalanceListener` eingeführt.
* `WordcountRebalanceListener` implementiert das neue Interface und
  kümmert sich um alle Kafka-Belange.
* `WordcountRecordHandler` kümmert sich nur noch um die Fachlogik.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/WordcountRebalanceListener.java diff | blob | history
src/main/java/de/juplo/kafka/WordcountRecordHandler.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.