trait KafkaTopicsV2[F[_]] extends KafkaTopics[F]
- Alphabetic
- By Inheritance
- KafkaTopicsV2
- KafkaTopics
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def beginningOffsets(partitions: Set[TopicPartition], timeout: FiniteDuration): F[Map[TopicPartition, Long]]
Returns the first offset for the specified partitions.
Returns the first offset for the specified partitions.
- Definition Classes
- KafkaTopics
- abstract def beginningOffsets(partitions: Set[TopicPartition]): F[Map[TopicPartition, Long]]
Returns the first offset for the specified partitions.
Returns the first offset for the specified partitions.
Timeout is determined by
default.api.timeout.ms, which is set using ConsumerSettings#withDefaultApiTimeout.- Definition Classes
- KafkaTopics
- abstract def endOffsets(partitions: Set[TopicPartition], timeout: FiniteDuration): F[Map[TopicPartition, Long]]
Returns the last offset for the specified partitions.
Returns the last offset for the specified partitions.
- Definition Classes
- KafkaTopics
- abstract def endOffsets(partitions: Set[TopicPartition]): F[Map[TopicPartition, Long]]
Returns the last offset for the specified partitions.
Returns the last offset for the specified partitions.
Timeout is determined by
request.timeout.ms, which is set using ConsumerSettings#withRequestTimeout.- Definition Classes
- KafkaTopics
- abstract def listTopics(timeout: FiniteDuration): F[Map[String, List[PartitionInfo]]]
Get metadata about partitions for all topics that the user is authorized to view.
Get metadata about partitions for all topics that the user is authorized to view. This method will issue a remote call to the server.
- abstract def listTopics: F[Map[String, List[PartitionInfo]]]
Get metadata about partitions for all topics that the user is authorized to view.
Get metadata about partitions for all topics that the user is authorized to view. This method will issue a remote call to the server.
Timeout is determined by
default.api.timeout.ms, which is set using ConsumerSettings#withDefaultApiTimeout. - abstract def offsetsForTimes(timestampsToSearch: Map[TopicPartition, Long], timeout: FiniteDuration): F[Map[TopicPartition, Option[OffsetAndTimestamp]]]
Look up the offsets for the given partitions by timestamp.
Look up the offsets for the given partitions by timestamp. The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition.
The consumer does not have to be assigned the partitions. If no messages exist yet for a partition, it will not exist in the returned map.
- abstract def offsetsForTimes(timestampsToSearch: Map[TopicPartition, Long]): F[Map[TopicPartition, Option[OffsetAndTimestamp]]]
Look up the offsets for the given partitions by timestamp.
Look up the offsets for the given partitions by timestamp. The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition.
The consumer does not have to be assigned the partitions. If no messages exist yet for a partition, it will not exist in the returned map.
Timeout is determined by
default.api.timeout.ms, which is set using ConsumerSettings#withDefaultApiTimeout. - abstract def partitionsFor(topic: String, timeout: FiniteDuration): F[List[PartitionInfo]]
Returns the partitions for the specified topic.
Returns the partitions for the specified topic.
- Definition Classes
- KafkaTopics
- abstract def partitionsFor(topic: String): F[List[PartitionInfo]]
Returns the partitions for the specified topic.
Returns the partitions for the specified topic.
Timeout is determined by
default.api.timeout.ms, which is set using ConsumerSettings#withDefaultApiTimeout.- Definition Classes
- KafkaTopics
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()