partition.assignment.strategy — Kafka Consumer Configuration
A list of class names or class types, ordered by preference, of supported partition assignment strategies that the client will use to distribute partition ownership amongst consumer instances when group management is used. Available options are:.
Description
A list of class names or class types, ordered by preference, of supported partition assignment strategies that the client will use to distribute partition ownership amongst consumer instances when group management is used. Available options are:
Default Values by Kafka Version
| Kafka Version | Default Value |
|---|---|
| 0.8.2 | range |
| 0.9.0 | range |
| 0.10.0 | range |
| 0.10.1 | [class org.apache.kafka.clients.consumer.RangeAssignor] |
| 0.10.2 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 0.11.0 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 1.0 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 1.1 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.0 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.1 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.2 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.3 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.4 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.5 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.6 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.7 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 2.8 | class org.apache.kafka.clients.consumer.RangeAssignor |
| 3.0 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.1 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.2 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.3 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.4 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.5 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.6 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.7 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.8 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 3.9 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 4.0 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 4.1 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
| 4.2 | class org.apache.kafka.clients.consumer.RangeAssignor,class org.apache.kafka.clients.consumer.CooperativeStickyAssignor |
Tuning Recommendation
| Profile | Recommended | Why |
|---|---|---|
| consumer / throughput | org.apache.kafka.clients.consumer.CooperativeStickyAssignor | Switching from the default RangeAssignor (eager, stops all consumption during rebalance) to CooperativeStickyAssignor enables incremental rebalancing: only partitions that actually need to move are revoked, while the rest continue consuming. Eliminates the 'stop-the-world' rebalance pause that can last seconds to minutes on large consumer groups, directly improving sustained throughput. |
| consumer / durability | org.apache.kafka.clients.consumer.CooperativeStickyAssignor | CooperativeStickyAssignor performs incremental rebalancing: only partitions that must move are revoked, all others keep processing without interruption. For durable consumers this eliminates the 'stop-the-world' rebalance gap where no consumer commits — the primary window for duplicate records in at-least-once systems. |
Related Configs
session.timeout.ms · max.poll.interval.ms · group.instance.id · enable.auto.commit
Manage Kafka configs across all your clusters with Conduktor Console — view, compare, and update configurations in one place.