Class | Description |
---|---|
PulsarFetcherManagerBase<T> |
Common fetcher manager abstraction for both ordered & unordered message.
|
PulsarOrderedFetcherManager<T> |
Pulsar's FetcherManager implementation for ordered consuming.
|
PulsarUnorderedFetcherManager<T> |
Pulsar's FetcherManager implementation for unordered consuming.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.