Packages

p

akka.kafka

internal

package internal

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

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.

Value Members

  1. object ConnectionChecker
    Annotations
    @InternalApi()
  2. object ConsumerProgressTrackerNoop extends ConsumerProgressTracking
    Annotations
    @InternalApi()
  3. object ConsumerResetProtection
    Annotations
    @InternalApi()
  4. object PartitionAssignmentHelpers

    Internal API.

    Internal API.

    Implementations of PartitionAssignmentHandler for internal use.

    Annotations
    @InternalApi()

Ungrouped