org.apache.flink.streaming.connectors.kafka.internal

Class Kafka010PartitionDiscoverer

java.lang.Object

org.apache.flink.streaming.connectors.kafka.internals.AbstractPartitionDiscoverer

org.apache.flink.streaming.connectors.kafka.internal.Kafka09PartitionDiscoverer

org.apache.flink.streaming.connectors.kafka.internal.Kafka010PartitionDiscoverer

@Internal
public class Kafka010PartitionDiscoverer
extends Kafka09PartitionDiscoverer

A partition discoverer that can be used to discover topics and partitions metadata from Kafka brokers via the Kafka 0.10 high-level consumer API.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.connectors.kafka.internals.AbstractPartitionDiscoverer

AbstractPartitionDiscoverer.ClosedException, AbstractPartitionDiscoverer.WakeupException

Constructor Summary

Constructors

Constructor and Description
Kafka010PartitionDiscoverer(KafkaTopicsDescriptor topicsDescriptor, int indexOfThisSubtask, int numParallelSubtasks, Properties kafkaProperties)

Method Summary

Methods inherited from class org.apache.flink.streaming.connectors.kafka.internal.Kafka09PartitionDiscoverer

closeConnections, getAllPartitionsForTopics, getAllTopics, initializeConnections, wakeupConnections

Methods inherited from class org.apache.flink.streaming.connectors.kafka.internals.AbstractPartitionDiscoverer

close, discoverPartitions, open, setAndCheckDiscoveredPartition, wakeup

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Kafka010PartitionDiscoverer

public Kafka010PartitionDiscoverer(KafkaTopicsDescriptor topicsDescriptor,
                                   int indexOfThisSubtask,
                                   int numParallelSubtasks,
                                   Properties kafkaProperties)