Packages

class MetadataClient extends AnyRef

Source
MetadataClient.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MetadataClient
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def close(): Unit
  2. def getBeginningOffsetForPartition(partition: TopicPartition): Future[Long]
  3. def getBeginningOffsets(partitions: Set[TopicPartition]): Future[Map[TopicPartition, Long]]
  4. def getCommittedOffsets(partitions: Set[TopicPartition]): Future[Map[TopicPartition, OffsetAndMetadata]]
  5. def getEndOffsetForPartition(partition: TopicPartition): Future[Long]
  6. def getEndOffsets(partitions: Set[TopicPartition]): Future[Map[TopicPartition, Long]]
  7. def getPartitionsFor(topic: String): Future[List[PartitionInfo]]
  8. def listTopics(): Future[Map[String, List[PartitionInfo]]]

Deprecated Value Members

  1. def getCommittedOffset(partition: TopicPartition): Future[OffsetAndMetadata]
    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.3) use getCommittedOffsets