ConsumerPartitionAssignor¶

ConsumerPartitionAssignor is an abstraction of partition assignors.

Contract¶

assign¶

GroupAssignment assign(
  Cluster metadata,
  GroupSubscription groupSubscription)

Used when:

• FIXME

name¶

String name()

Used when:

• FIXME

Implementations¶

• AbstractPartitionAssignor
• StreamsPartitionAssignor (Kafka Streams)

onAssignment¶

void onAssignment(
  Assignment assignment,
  ConsumerGroupMetadata metadata)

onAssignment...FIXME

onAssignment is used when:

• FIXME

supportedProtocols¶

List<RebalanceProtocol> supportedProtocols()

Default: RebalanceProtocol.EAGER

supportedProtocols is used when:

• FIXME

subscriptionUserData¶

ByteBuffer subscriptionUserData(
  Set<String> topics)

subscriptionUserData is null by default.

subscriptionUserData is used when:

• ConsumerCoordinator is requested for metadata