Packages

final class Chain extends PartitionAssignmentHandler

Annotations
@InternalApi()
Source
PartitionAssignmentHelpers.scala
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Chain
  2. PartitionAssignmentHandler
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Chain(handler1: PartitionAssignmentHandler, handler2: PartitionAssignmentHandler)

Value Members

  1. def onAssign(assignedTps: Set[TopicPartition], consumer: RestrictedConsumer): Unit

    See org.apache.kafka.clients.consumer.ConsumerRebalanceListener#onPartitionsAssigned

    assignedTps

    The list of partitions that are now assigned to the consumer (may include partitions previously assigned to the consumer)

    consumer

    The pekko.kafka.RestrictedConsumer gives some access to the internally used Consumer

    Definition Classes
    ChainPartitionAssignmentHandler
  2. def onLost(lostTps: Set[TopicPartition], consumer: RestrictedConsumer): Unit

    Called when partition metadata has changed and partitions no longer exist.

    Called when partition metadata has changed and partitions no longer exist. This can occur if a topic is deleted or if the leader's metadata is stale. See org.apache.kafka.clients.consumer.ConsumerRebalanceListener#onPartitionsLost

    lostTps

    The list of partitions that are no longer valid

    consumer

    The pekko.kafka.RestrictedConsumer gives some access to the internally used Consumer

    Definition Classes
    ChainPartitionAssignmentHandler
  3. def onRevoke(revokedTps: Set[TopicPartition], consumer: RestrictedConsumer): Unit

    See org.apache.kafka.clients.consumer.ConsumerRebalanceListener#onPartitionsRevoked

    revokedTps

    The list of partitions that were revoked from the consumer

    consumer

    The pekko.kafka.RestrictedConsumer gives some access to the internally used Consumer

    Definition Classes
    ChainPartitionAssignmentHandler
  4. def onStop(revokedTps: Set[TopicPartition], consumer: RestrictedConsumer): Unit

    Called before a consumer is closed.

    consumer

    The pekko.kafka.RestrictedConsumer gives some access to the internally used Consumer

    Definition Classes
    ChainPartitionAssignmentHandler
  5. def toString(): String
    Definition Classes
    Chain → AnyRef → Any