Constructor and Description |
---|
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context) |
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context,
PulsarSourceEnumState enumState) |
Modifier and Type | Method and Description |
---|---|
static PulsarSubscriber |
PulsarSubscriber.getTopicListSubscriber(List<String> topics) |
static PulsarSubscriber |
PulsarSubscriber.getTopicPatternSubscriber(Pattern topicPattern,
org.apache.pulsar.client.api.RegexSubscriptionMode subscriptionMode) |
Modifier and Type | Class and Description |
---|---|
class |
BasePulsarSubscriber
PulsarSubscriber abstract class to simplify Pulsar admin related operations.
|
class |
TopicListSubscriber
the implements of consuming multiple topics.
|
class |
TopicPatternSubscriber
Subscribe to matching topics based on topic pattern.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.