Description
Currently the task assignment in TaskAssignor is not deterministic. During cluster restart or rolling restart, even though the participating worker nodes are the same, but the TaskAssignor is not able to maintain a deterministic mapping, so about 20% partitions will be reassigned which would cause state repopulation on cluster restart time.
When the participating worker nodes are not changed, we really just want to keep the old task assignment.
Attachments
Issue Links
- is a clone of
-
KAFKA-3740 Enable configuration of RocksDBStores
-
- Resolved
-
- links to
