RangeAssignor
RangeAssignor is a Kafka consumer partition-assignment algorithm that sorts consumers and partitions and assigns each topic’s partitions in contiguous ranges.
Kafka for Architects
RangeAssignor is a Kafka consumer partition assignor that orders consumers and assigns each topic's partitions sequentially in contiguous ranges.
- How it is used
- Assigns Kafka consumer-group partitions sequentially when predictable, cross-topic consumer placement matters.
- How deep it goes
- Defines ordering, contiguous assignment, co-partitioning, and eager-rebalance consequences without detailing assignor implementation internals.
- Examples
- Uses keyed Invoices and Profiles topics to demonstrate same-customer processing on one consumer instance.
- What you can do after
- Evaluate whether partition alignment and cross-topic correlation justify eager-rebalance downtime for a consumer group.
Apache Kafka in Action
The Range Assignor is a Kafka partition-assignment algorithm that assigns corresponding partition numbers from subscribed topics to the same consumers.
- How it is used
- Assigns matching partition numbers across topics to the same consumer when a consumer group processes related streams together.
- How deep it goes
- Explains default behavior, rebalance leadership, configuration consistency, partition examples, join use, and the risk of idle consumers.
- Examples
- Uses two two-partition product topics, three consumers, matching product keys, and a Kafka Streams join scenario.
- What you can do after
- Evaluate cross-topic processing needs, configure a consistent assignment strategy, and choose Kafka Streams for joins.
Related concepts
- consumer assignment strategykind of · A consumer assignment strategy is the algorithm that distributes Kafka topic partitions among members of a consumer group.
- eager rebalancekind of · Eager rebalancing is a consumer-group protocol in which all consumers revoke existing partition assignments before new assignments are distributed.
- RoundRobinAssignoralternative to · RoundRobinAssignor is a Kafka consumer partition-assignment algorithm that distributes subscribed-topic partitions cyclically and evenly across consumer-group members.
- joinuses · A join is an operation that combines records or rows from multiple data sources according to specified matching conditions or relationships.
These guides are generated from the text of Manning books by Manning's knowledge graph and link to the sections they draw on. The full books are available on liveBook and at manning.com.