Type Members

1.  trait ConsumerAssignmentTrackingListener extends AnyRef

   Listen for changes to the consumer assignments.

   Listen for changes to the consumer assignments.

   Annotations

   @InternalApi()

2.  final class ConsumerProgressTrackerImpl extends ConsumerProgressTracking

   Track the progress/state of the consumer.

   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()

3.  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.

   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()

4.  sealed trait ConsumerResetProtection extends AnyRef

   Added as part of https://github.com/akka/alpakka-kafka/issues/1286 to avoid reprocessing data in case of Kafka temporarily "losing" an offset.

   Added as part of https://github.com/akka/alpakka-kafka/issues/1286 to avoid reprocessing data in case of Kafka temporarily "losing" an offset.

   Annotations

   @InternalApi()

5.  final case class SafeOffsetAndTimestamp(offset: Long, timestamp: Long) extends Product with Serializable

   Maintain our own OffsetAndTimestamp which can tolerate negative timestamps, which happen for old clients that don't set timestamp explicitly.