@VisibleForTesting public static class KafkaSourceEnumerator.PartitionOffsetsRetrieverImpl extends Object implements OffsetsInitializer.PartitionOffsetsRetriever, AutoCloseable
Constructor and Description |
---|
PartitionOffsetsRetrieverImpl(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer,
org.apache.kafka.clients.admin.AdminClient adminClient,
String groupId) |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.kafka.common.TopicPartition,Long> |
beginningOffsets(Collection<org.apache.kafka.common.TopicPartition> partitions) |
void |
close() |
Map<org.apache.kafka.common.TopicPartition,Long> |
committedOffsets(Collection<org.apache.kafka.common.TopicPartition> partitions)
The group id should be the set for
KafkaSource before invoking this
method. |
Map<org.apache.kafka.common.TopicPartition,Long> |
endOffsets(Collection<org.apache.kafka.common.TopicPartition> partitions) |
Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndTimestamp> |
offsetsForTimes(Map<org.apache.kafka.common.TopicPartition,Long> timestampsToSearch) |
public PartitionOffsetsRetrieverImpl(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer, org.apache.kafka.clients.admin.AdminClient adminClient, String groupId)
public Map<org.apache.kafka.common.TopicPartition,Long> committedOffsets(Collection<org.apache.kafka.common.TopicPartition> partitions)
OffsetsInitializer.PartitionOffsetsRetriever
KafkaSource
before invoking this
method. Otherwise an IllegalStateException
will be thrown.committedOffsets
in interface OffsetsInitializer.PartitionOffsetsRetriever
KafkaAdminClient.listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions)
public Map<org.apache.kafka.common.TopicPartition,Long> endOffsets(Collection<org.apache.kafka.common.TopicPartition> partitions)
endOffsets
in interface OffsetsInitializer.PartitionOffsetsRetriever
KafkaConsumer.endOffsets(Collection)
public Map<org.apache.kafka.common.TopicPartition,Long> beginningOffsets(Collection<org.apache.kafka.common.TopicPartition> partitions)
beginningOffsets
in interface OffsetsInitializer.PartitionOffsetsRetriever
KafkaConsumer.beginningOffsets(Collection)
public Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndTimestamp> offsetsForTimes(Map<org.apache.kafka.common.TopicPartition,Long> timestampsToSearch)
offsetsForTimes
in interface OffsetsInitializer.PartitionOffsetsRetriever
KafkaConsumer.offsetsForTimes(Map)
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.