DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
- --reassignment-batch-size — caps how many topic partitions are submitted per step (semantics differ slightly depending on mode; see below). 0 preserves legacy behavior (single request for the entire plan).
- --incremental — optional mode used with--reassignment-batch-size > 0 to keep at most Npartition reassignments in flight for this execution, submitting the next partition from a deterministic queue when a slot frees up.
- --reassignment-poll-interval-ms — how long the tool sleeps between polls while waiting for batch completion (non-incremental, between batches) and while driving incremental submissions; default 500 ms.
Ordering for both modes is (topic name, partition index), not the order of entries in the JSON file.
...
CLI (kafka-reassign-partitions.sh)
Option | Applies to | Semantics |
--reassignment-batch-size <int> | --execute only |
|
--incremental | --execute only | Requires --reassignment-batch-size > 0. Mutually exclusive interpretation of batch size as in-flight cap (see above). |
--reassignment-poll-interval-ms <long> | --execute only | Milliseconds to sleep between progress polls when the tool is waiting on reassignment state. Default 500. |
Validation and compatibility
- --reassignment-batch-size must be ≥ 0. Negative values are rejected.
- --incremental without --reassignment-batch-size > 0 is rejected at argument validation time.
- --reassignment-batch-size, --incremental and --reassignment-poll-interval-incremental ms are not permitted with --list, --generate, --verify, or --cancel (same pattern as other execute-only options).
- --reassignment-poll-interval-ms must be > 0. Negative values are rejected.
Programmatic API
ReassignPartitionsCommand.executeAssignment gains parameters:
...