Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka.internal | |
org.apache.flink.streaming.connectors.kafka.internals |
Modifier and Type | Method and Description |
---|---|
protected List<KafkaTopicPartition> |
KafkaPartitionDiscoverer.getAllPartitionsForTopics(List<String> topics) |
protected List<KafkaTopicPartition> |
Kafka09PartitionDiscoverer.getAllPartitionsForTopics(List<String> topics) |
protected List<String> |
KafkaPartitionDiscoverer.getAllTopics() |
protected List<String> |
Kafka09PartitionDiscoverer.getAllTopics() |
Modifier and Type | Method and Description |
---|---|
List<KafkaTopicPartition> |
AbstractPartitionDiscoverer.discoverPartitions()
Execute a partition discovery attempt for this subtask.
|
protected abstract List<KafkaTopicPartition> |
AbstractPartitionDiscoverer.getAllPartitionsForTopics(List<String> topics)
Fetch the list of all partitions for a specific topics list from Kafka.
|
protected abstract List<String> |
AbstractPartitionDiscoverer.getAllTopics()
Fetch the list of all topics from Kafka.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.