c

akka.kafka

RestrictedConsumer

final class RestrictedConsumer extends AnyRef

Offers parts of the org.apache.kafka.clients.consumer.Consumer API which becomes available to the akka.kafka.scaladsl.PartitionAssignmentHandler callbacks.

Annotations
@ApiMayChange()
Source
RestrictedConsumer.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RestrictedConsumer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new RestrictedConsumer(consumer: Consumer[_, _], duration: Duration)

Value Members

  1. def assignment(): Set[TopicPartition]

    See org.apache.kafka.clients.consumer.KafkaConsumer#assignment

  2. def beginningOffsets(tps: Collection[TopicPartition]): Map[TopicPartition, Long]

    See org.apache.kafka.clients.consumer.KafkaConsumer#beginningOffsets()

  3. def commitSync(offsets: Map[TopicPartition, OffsetAndMetadata]): Unit

    See org.apache.kafka.clients.consumer.KafkaConsumer#commitSync(Map,java.time.Duration)

  4. def committed(partitions: Set[TopicPartition]): Map[TopicPartition, OffsetAndMetadata]

    See org.apache.kafka.clients.consumer.KafkaConsumer#committed(java.util.Set[TopicPartition],java.time.Duration)

  5. def endOffsets(tps: Collection[TopicPartition]): Map[TopicPartition, Long]

    See org.apache.kafka.clients.consumer.KafkaConsumer#endOffsets(java.util.Collection[TopicPartition],java.time.Duration)

  6. def offsetsForTimes(timestampsToSearch: Map[TopicPartition, Long]): Map[TopicPartition, OffsetAndTimestamp]

    See org.apache.kafka.clients.consumer.KafkaConsumer#offsetsForTimes(java.util.Map[TopicPartition,Long],java.time.Duration)

  7. def position(tp: TopicPartition): Long

    See java.time.Duration)

  8. def seek(tp: TopicPartition, offset: Long): Unit

    See Long)

  9. def seekToBeginning(tps: Collection[TopicPartition]): Unit

    See org.apache.kafka.clients.consumer.KafkaConsumer#seekToBeginning(java.util.Collection[TopicPartition])

  10. def seekToEnd(tps: Collection[TopicPartition]): Unit

    See org.apache.kafka.clients.consumer.KafkaConsumer#seekToEnd(java.util.Collection[TopicPartition])

Deprecated Value Members

  1. def committed(tp: TopicPartition): OffsetAndMetadata

    See org.apache.kafka.clients.consumer.KafkaConsumer#committed(TopicPartition,java.time.Duration)

    See org.apache.kafka.clients.consumer.KafkaConsumer#committed(TopicPartition,java.time.Duration)

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.5) use committed(java.util.Set[TopicPartition])