Map<String, List<TopicPartition>> assign(
Map<String, Integer> partitionsPerTopic,
Map<String, Subscription> subscriptions)AbstractPartitionAssignor
AbstractPartitionAssignor is the extension of the PartitionAssignor contract for partition assignors that can perform group assignment given partition counts and member subscriptions.
|
Note
|
AbstractPartitionAssignor is a Java abstract class and cannot be created directly. It is created indirectly for the concrete PartitionAssignors.
|
| Method | Description |
|---|---|
|
Performs group assignment given partition counts and member subscriptions Used exclusively when requested to assign (given cluster metadata and member subscriptions) |
| AbstractPartitionAssignor | Description |
|---|---|
assign Method
Map<String, Assignment> assign(
Cluster metadata,
Map<String, Subscription> subscriptions)|
Note
|
assign is part of the PartitionAssignor Contract to perform group assignment given cluster metadata and member subscriptions.
|
assign…FIXME