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