projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: efa9423) | patch
Der Producer erkennt die Änderung der Partitionierung schneller
authorKai Moritz <kai@juplo.de>
Sat, 2 Apr 2022 17:37:01 +0000 (19:37 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 2 Apr 2022 17:37:01 +0000 (19:37 +0200)
commit5c0b7b3cf822c0802c3d802a47934b6304eaed7c
tree786aefc29a1d4f3044244317b147f0d89c6e9534tree | snapshot
parentefa942341314e29f68b895ad4c8cee766c895236commit | diff
Der Producer 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
src/main/java/de/juplo/kafka/EndlessProducer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.