Interface | Description |
---|---|
HasOffsetRanges |
Represents any object that has a collection of
OffsetRange s. |
Class | Description |
---|---|
Broker |
Represents the host and port info for a Kafka broker.
|
KafkaCluster |
:: DeveloperApi ::
Convenience methods for interacting with a Kafka cluster.
|
KafkaCluster.LeaderOffset | |
KafkaCluster.LeaderOffset$ | |
KafkaCluster.SimpleConsumerConfig |
High-level kafka consumers connect to ZK.
|
KafkaCluster.SimpleConsumerConfig$ | |
KafkaUtils | |
OffsetRange |
Represents a range of offsets from a single Kafka TopicAndPartition.
|