projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: c4307f7) | patch
Der Consumer erkennt die Änderung der Partitionierung schneller
authorKai Moritz <kai@juplo.de>
Sat, 2 Apr 2022 15:18:06 +0000 (17:18 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 2 Apr 2022 15:18:20 +0000 (17:18 +0200)
commitcbce022445f6125f960e5095d2083e4cf58dfb5e
treedf0322928114d4a8c040f4df8c476f99dfae1761tree | snapshot
parentc4307f77ada5184c5c657f86ff086bdf1505c70bcommit | diff
Der Consumer erkennt die Änderung der Partitionierung schneller

* `metadata.max.age.ms` auf 1000 heruntergesetzt (Default 5 min)
* Dadurch wird die Änderung der Anzahl an Partitionen zeitnah erkannt
README.sh diff | blob | history
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.