t

akka.kafka.internal

ConsumerAssignmentTrackingListener

trait ConsumerAssignmentTrackingListener extends AnyRef

Listen for changes to the consumer assignments.

Annotations
@InternalApi()
Source
ConsumerProgressTracking.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
ConsumerProgressTrackerImpl, ConsumerProgressTrackerNoop, ConsumerProgressTracking
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConsumerAssignmentTrackingListener
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def assignedPositions(assignedTps: Set[TopicPartition], assignedOffsets: Map[TopicPartition, Long]): Unit
  2. def revoke(revokedTps: Set[TopicPartition]): Unit