projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 4c4eaa9) | patch
Für eine Übersichtliche Übergabe sollte CooperativeStickyAssignor aktiv sein
authorKai Moritz <kai@juplo.de>
Tue, 2 Aug 2022 19:00:36 +0000 (21:00 +0200)
committerKai Moritz <kai@juplo.de>
Tue, 2 Aug 2022 19:01:08 +0000 (21:01 +0200)
commit5be01a7ce4a1362684ecf22d82ecf8800d5d0a34
tree68ac9bc0703a8396c12d9190a2acd46b226e36e7tree | snapshot
parent4c4eaa9bf0d40ca631ac78d3a51c36cfcda4fe6fcommit | diff
Für eine Übersichtliche Übergabe sollte CooperativeStickyAssignor aktiv sein

* Per Default ist immer noch der RangeAssignor vorgegeben, so dass die
  Partitionen bei jedem Rebalance komplett neu zugeordnet werden.
* Um bei der Betrachtung der Effekte von Sauberem Stop vs. Kill vs. Freeze
  den Überblick behalten zu können, wurde der CooperativeStickyAssignor
  aktiviert.
src/main/java/de/juplo/kafka/SimpleConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.