refactor: Handling der Partitionen in WordcountRebalanceListener
authorKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 09:53:46 +0000 (11:53 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 14:45:21 +0000 (16:45 +0200)
commitfc682d9890787ef363b3e189f6f880a043f3c541
treeba1a94f93445813b1b89f5d87f0badd3c3301bf7
parent818c1eb862247e25abf9f7d91d5a73e3e3789a39
refactor: Handling der Partitionen in WordcountRebalanceListener
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/RecordHandler.java
src/main/java/de/juplo/kafka/WordcountRebalanceListener.java
src/main/java/de/juplo/kafka/WordcountRecordHandler.java
src/test/java/de/juplo/kafka/TestRecordHandler.java