Skip to content

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

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