t

akka.kafka

AutoSubscription

sealed trait AutoSubscription extends Subscription

Kafka-speak for these is "Subscriptions".

Source
Subscriptions.scala
Linear Supertypes
Subscription, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AutoSubscription
  2. Subscription
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def partitionAssignmentHandler: PartitionAssignmentHandler
    Annotations
    @InternalApi()
  2. abstract def rebalanceListener: Option[ActorRef]

    ActorRef which is to receive akka.kafka.ConsumerRebalanceEvent signals when rebalancing happens

    ActorRef which is to receive akka.kafka.ConsumerRebalanceEvent signals when rebalancing happens

    Definition Classes
    AutoSubscription → Subscription
  3. abstract def renderStageAttribute: String
    Definition Classes
    Subscription
  4. abstract def withPartitionAssignmentHandler(handler: PartitionAssignmentHandler): AutoSubscription
    Annotations
    @ApiMayChange()
  5. abstract def withPartitionAssignmentHandler(handler: PartitionAssignmentHandler): AutoSubscription
    Annotations
    @ApiMayChange()
  6. abstract def withRebalanceListener(ref: ActorRef): AutoSubscription

    Configure this actor ref to receive akka.kafka.ConsumerRebalanceEvent signals

    Configure this actor ref to receive akka.kafka.ConsumerRebalanceEvent signals

    Definition Classes
    AutoSubscription → Subscription