Packages

t

org.apache.pekko.kafka.internal

ConsumerProgressTracking

trait ConsumerProgressTracking extends ConsumerAssignmentTrackingListener

Track the current state of the consumer: what offsets it has requested, received and committed, filtering by the current assignments to the consumer. When a partition is assigned to the consumer for the first time, its assigned offset is the current position of the partition (uses underlying Kafka Consumer to leverage the configured offset-reset policy).

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

Value Members

  1. def addProgressTrackingCallback(callback: ConsumerAssignmentTrackingListener): Unit
  2. def assignedPositions(assignedTps: Set[TopicPartition], assignedOffsets: Map[TopicPartition, Long]): Unit
    Definition Classes
    ConsumerAssignmentTrackingListener
  3. def assignedPositionsAndSeek(assignedTps: Set[TopicPartition], consumer: Consumer[_, _], positionTimeout: Duration): Unit
  4. def commitRequested(offsets: Map[TopicPartition, OffsetAndMetadata]): Unit
  5. def commitRequested: Map[TopicPartition, OffsetAndMetadata]
  6. def committed(offsets: Map[TopicPartition, OffsetAndMetadata]): Unit
  7. def committedOffsets: Map[TopicPartition, OffsetAndMetadata]
  8. def received[K, V](records: ConsumerRecords[K, V]): Unit
  9. def receivedMessages: Map[TopicPartition, SafeOffsetAndTimestamp]
  10. def revoke(revokedTps: Set[TopicPartition]): Unit
    Definition Classes
    ConsumerAssignmentTrackingListener