public abstract class BasePulsarSubscriber extends Object implements PulsarSubscriber
Constructor and Description |
---|
BasePulsarSubscriber() |
Modifier and Type | Method and Description |
---|---|
protected TopicMetadata |
queryTopicMetadata(org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
String topicName) |
protected List<TopicPartition> |
toTopicPartitions(String topic,
int partitionId,
List<TopicRange> ranges,
RangeGenerator.KeySharedMode mode) |
protected List<TopicPartition> |
toTopicPartitions(TopicMetadata metadata,
List<TopicRange> ranges,
RangeGenerator.KeySharedMode mode) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSubscribedTopicPartitions, getTopicListSubscriber, getTopicPatternSubscriber
protected TopicMetadata queryTopicMetadata(org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin, String topicName)
protected List<TopicPartition> toTopicPartitions(TopicMetadata metadata, List<TopicRange> ranges, RangeGenerator.KeySharedMode mode)
protected List<TopicPartition> toTopicPartitions(String topic, int partitionId, List<TopicRange> ranges, RangeGenerator.KeySharedMode mode)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.