projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: e53004f) | patch
Fehler in Logging-Ausgabe korrigiert
authorKai Moritz <kai@juplo.de>
Sun, 24 Jul 2022 14:12:04 +0000 (16:12 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 14:44:16 +0000 (16:44 +0200)
commit5b4d66eaf6cac9261ab5c36174a16b04c62adf30
tree1a20c9be86f69c7b013c75fcd6f6e297ed7dcdf0tree | snapshot
parente53004f3133b737699e995a3b18fff28203a0e8ccommit | diff
Fehler in Logging-Ausgabe korrigiert

* Der über den Merge hinzugefügt Test hat einen Fehler aufgedeckt.
* In onPartitionsRevoked() wurde bei der Berechnung der verarbeiteten
  Nachrichten für die Log-Ausgabe ein Nullzeiger dereferenziert.
* Ursache dafür war, dass die Map `offsets` in der Version, die die Offsets
  speichert gar nicht mehr gepflegt wurde.
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.