projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 5b4d66e) | patch
Ausgabe der verarbeiteten Nachrichten im Revoke-Callback entfernt
authorKai Moritz <kai@juplo.de>
Sun, 24 Jul 2022 14:15:23 +0000 (16:15 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 14:44:56 +0000 (16:44 +0200)
commit34d37c55d7cf830c6d2bdaf747f0938eb557bef3
tree80308dd8a1f97a7cb7074750ef81272b6b073e4ftree | snapshot
parent5b4d66eaf6cac9261ab5c36174a16b04c62adf30commit | diff
Ausgabe der verarbeiteten Nachrichten im Revoke-Callback entfernt

* Es musste allein für diese Ausgabe eine Map mit den zuletzt eingelesenen
  Offset-Positionen gepflegt werden.
* Das ist zu viel Overhead, für die Randmeldung im Log.
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.