final class ConsumerProgressTrackerImpl extends ConsumerProgressTracking
Track the progress/state of the consumer. We generally try to be 'fast' with handling the partitions we track; most of the smarts are expected to be handled outside this class. For example, we will update any offsets to commit - commitRequested - without regard for what had previously been assigned or revoked from the consumer. Thus, care should be taken when managing state of the consumer and making updates.
The only case we try and be "smart" is during received, where we will filter out offsets that are not currently assigned; ensuring that we don't try to waste cycles on partitions that we no longer care about. This matches downstream behavior where the SourceLogicBuffer filters out revoked partitions.
- Annotations
- @InternalApi()
- Source
- ConsumerProgressTracking.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ConsumerProgressTrackerImpl
- ConsumerProgressTracking
- ConsumerAssignmentTrackingListener
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new ConsumerProgressTrackerImpl()
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
- def addProgressTrackingCallback(callback: ConsumerAssignmentTrackingListener): Unit
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerProgressTracking
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def assignedPositions(assignedTps: Set[TopicPartition], assignedOffsets: Map[TopicPartition, Long]): Unit
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerAssignmentTrackingListener
- def assignedPositionsAndSeek(assignedTps: Set[TopicPartition], consumer: Consumer[_, _], positionTimeout: Duration): Unit
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerProgressTracking
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def commitRequested(offsets: Map[TopicPartition, OffsetAndMetadata]): Unit
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerProgressTracking
- def commitRequested: Map[TopicPartition, OffsetAndMetadata]
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerProgressTracking
- def committed(offsets: Map[TopicPartition, OffsetAndMetadata]): Unit
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerProgressTracking
- def committedOffsets: Map[TopicPartition, OffsetAndMetadata]
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerProgressTracking
- 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()
- def received[K, V](received: ConsumerRecords[K, V]): Unit
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerProgressTracking
- def receivedMessages: Map[TopicPartition, SafeOffsetAndTimestamp]
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerProgressTracking
- def revoke(revokedTps: Set[TopicPartition]): Unit
- Definition Classes
- ConsumerProgressTrackerImpl → ConsumerAssignmentTrackingListener
- 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()