Skip to content

Latest commit

 

History

History
71 lines (51 loc) · 1.98 KB

kafka-consumer-internals-PartitionAssignor.adoc

File metadata and controls

71 lines (51 loc) · 1.98 KB

PartitionAssignor Contract

PartitionAssignor is the abstraction of partition assignors that are identified by name and can perform partition assignment.

Table 1. PartitionAssignor Contract
Method Description

assign

 
Map<String, Assignment> assign(
  Cluster metadata,
  Map<String, Subscription> subscriptions)

Assigns partitions to the members of a consumer group

Used exclusively when ConsumerCoordinator is requested to perform partition assignment

name

 
String name()

Used when ConsumerCoordinator is requested to metadata, lookupAssignor, and performAssignment (only for logging purposes)

onAssignment

 
void onAssignment(Assignment assignment)

Used exclusively when ConsumerCoordinator is requested to onJoinComplete

subscription

 
Subscription subscription(Set<String> topics)

Used exclusively when ConsumerCoordinator is requested to metadata
Table 2. PartitionAssignors (Direct Implementations)
PartitionAssignor Description

AbstractPartitionAssignor

Extension for collecting partition counts

StreamsPartitionAssignor

Default PartitionAssignor in Kafka Streams