KafkaTopics
Attributes
- Source
- KafkaTopics.scala
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
- Known subtypes
-
trait KafkaTopicsV2[F]
Members list
Value members
Abstract methods
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.
Attributes
- Source
- KafkaTopics.scala
Returns the first offset for the specified partitions.
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.
Attributes
- Source
- KafkaTopics.scala
Returns the last offset for the specified partitions.
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.
Attributes
- Source
- KafkaTopics.scala
Returns the partitions for the specified topic.