Package | Description |
---|---|
org.apache.flink.connector.kafka.source.enumerator | |
org.apache.flink.connector.kafka.source.enumerator.initializer |
Modifier and Type | Class and Description |
---|---|
static class |
KafkaSourceEnumerator.PartitionOffsetsRetrieverImpl
The implementation for offsets retriever with a consumer and an admin client.
|
Modifier and Type | Method and Description |
---|---|
Map<org.apache.kafka.common.TopicPartition,Long> |
NoStoppingOffsetsInitializer.getPartitionOffsets(Collection<org.apache.kafka.common.TopicPartition> partitions,
OffsetsInitializer.PartitionOffsetsRetriever partitionOffsetsRetriever) |
Map<org.apache.kafka.common.TopicPartition,Long> |
OffsetsInitializer.getPartitionOffsets(Collection<org.apache.kafka.common.TopicPartition> partitions,
OffsetsInitializer.PartitionOffsetsRetriever partitionOffsetsRetriever)
Get the initial offsets for the given Kafka partitions.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.