public class TopicPatternSubscriber extends BasePulsarSubscriber
Constructor and Description |
---|
TopicPatternSubscriber(Pattern topicPattern,
org.apache.pulsar.client.api.RegexSubscriptionMode subscriptionMode) |
Modifier and Type | Method and Description |
---|---|
Set<TopicPartition> |
getSubscribedTopicPartitions(org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
RangeGenerator rangeGenerator,
int parallelism)
Get a set of subscribed
TopicPartition s. |
queryTopicMetadata, toTopicPartitions, toTopicPartitions
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getTopicListSubscriber, getTopicPatternSubscriber
public TopicPatternSubscriber(Pattern topicPattern, org.apache.pulsar.client.api.RegexSubscriptionMode subscriptionMode)
public Set<TopicPartition> getSubscribedTopicPartitions(org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin, RangeGenerator rangeGenerator, int parallelism)
PulsarSubscriber
TopicPartition
s. The method could throw IllegalStateException
, an extra try catch is required.pulsarAdmin
- The admin interface used to retrieve subscribed topic partitions.rangeGenerator
- The range for different partitions.parallelism
- The parallelism of flink source.TopicPartition
for each pulsar topic partition.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.