- trait ConsumerAssignmentTrackingListener extends AnyRef
Listen for changes to the consumer assignments.
- final class ConsumerProgressTrackerImpl extends ConsumerProgressTracking
Track the progress/state of the consumer.
- 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.
- 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.
- 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.