projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 007ec5a) | 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>
Sun, 24 Jul 2022 14:12:04 +0000 (16:12 +0200)
commita66978002ec0a060d5eb33a6348ec234fe129908
tree5ccb236ef86d3a125dc27805ef781449c992bdf0tree | snapshot
parent007ec5a0cb23a52abe56776d73648b0f283a24a6commit | 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.