Packages

c

akka.kafka.Metadata

GetBeginningOffsets

final case class GetBeginningOffsets(partitions: Set[TopicPartition]) extends Request with NoSerializationVerificationNeeded with Product with Serializable

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

Warning: KafkaConsumer documentation states that this method may block indefinitely if the partition does not exist.

Source
Metadata.scala
Linear Supertypes
Serializable, Product, Equals, NoSerializationVerificationNeeded, Request, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GetBeginningOffsets
  2. Serializable
  3. Product
  4. Equals
  5. NoSerializationVerificationNeeded
  6. Request
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new GetBeginningOffsets(partitions: Set[TopicPartition])

Value Members

  1. val partitions: Set[TopicPartition]
  2. def productElementNames: Iterator[String]
    Definition Classes
    Product