trait PartitionAssignmentHandler extends AnyRef
The API is new and may change in further releases.
Allows the user to execute user code when Kafka rebalances partitions between consumers, or an Alpakka Kafka consumer is stopped.
Use with care: These callbacks are called synchronously on the same thread Kafka's poll() is called.
A warning will be logged if a callback takes longer than the configured partition-handler-warning.
There is no point in calling Committable's commit methods as their committing won't be executed as long as any of
the callbacks in this class are called. Calling commitSync on the passed akka.kafka.RestrictedConsumer is available.
This complements the methods of Kafka's ConsumerRebalanceListener with
an onStop callback which is called before Consumer.close.
- Alphabetic
- By Inheritance
- PartitionAssignmentHandler
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract 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 akka.kafka.RestrictedConsumer gives some access to the internally used Consumer
- abstract 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 akka.kafka.RestrictedConsumer gives some access to the internally used Consumer
- abstract 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 akka.kafka.RestrictedConsumer gives some access to the internally used Consumer
- abstract def onStop(currentTps: Set[TopicPartition], consumer: RestrictedConsumer): Unit
Called before a consumer is closed.
Called before a consumer is closed. See org.apache.kafka.clients.consumer.ConsumerRebalanceListener#onPartitionsRevoked
- currentTps
The list of partitions that are currently assigned to the consumer
- consumer
The akka.kafka.RestrictedConsumer gives some access to the internally used Consumer
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()