T
- The message type for pulsar decoded message.@Internal public class PulsarOrderedFetcherManager<T> extends PulsarFetcherManagerBase<T>
Consumer
inside the PulsarOrderedPartitionSplitReader
.fetchers
Constructor and Description |
---|
PulsarOrderedFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<T>>> elementsQueue,
java.util.function.Supplier<SplitReader<PulsarMessage<T>,PulsarPartitionSplit>> splitReaderSupplier) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledgeMessages(Map<TopicPartition,org.apache.pulsar.client.api.MessageId> cursorsToCommit) |
addSplits, getOrCreateFetcher, startFetcher
checkErrors, close, createSplitFetcher, getNumAliveFetchers, maybeShutdownFinishedFetchers
public PulsarOrderedFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<T>>> elementsQueue, java.util.function.Supplier<SplitReader<PulsarMessage<T>,PulsarPartitionSplit>> splitReaderSupplier)
public void acknowledgeMessages(Map<TopicPartition,org.apache.pulsar.client.api.MessageId> cursorsToCommit)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.