-
MethodDescriptionSince 2.0. See
PulsarAdmin.topics()
since 2.0. SeePulsarAdmin.tenants()
in favor ofPulsarAdmin.sinks()
in favor ofPulsarAdmin.sources()
UseTopics.delete(String, boolean)
instead because parameter `deleteSchema` is always trueUseTopics.deleteAsync(String, boolean)
instead because parameter `deleteSchema` is always trueUseTopics.deletePartitionedTopic(String, boolean)
instead because parameter `deleteSchema` is always trueUseTopics.deletePartitionedTopicAsync(String, boolean)
instead because parameter `deleteSchema` is always trueUseTopicPolicies.removeDeduplicationStatus(String)
instead.UseTopicPolicies.removeDeduplicationStatusAsync(String)
instead.UseTopicPolicies.getBacklogQuotaMap(String)
instead.UseTopicPolicies.getBacklogQuotaMap(String, boolean)
instead.UseTopicPolicies.getCompactionThreshold(String)
instead.UseTopicPolicies.getCompactionThresholdAsync(String)
instead.UseTopicPolicies.getDeduplicationStatus(String)
instead.UseTopicPolicies.getDeduplicationStatusAsync(String)
instead.UseTopicPolicies.getDeduplicationStatus(String)
instead.UseTopicPolicies.getDeduplicationStatusAsync(String)
instead.UseTopicPolicies.getDelayedDeliveryPolicy(String)
instead.UseTopicPolicies.getDelayedDeliveryPolicyAsync(String)
instead.UseTopicPolicies.getDispatchRate(String)
instead.UseTopicPolicies.getDispatchRate(String, boolean)
instead.UseTopicPolicies.getDispatchRateAsync(String)
instead.UseTopicPolicies.getDispatchRateAsync(String, boolean)
instead.UseTopicPolicies.getInactiveTopicPolicies(String)
instead.UseTopicPolicies.getInactiveTopicPoliciesAsync(String)
instead.UseTopicPolicies.getMaxConsumers(String)
instead.UseTopicPolicies.getMaxConsumers(String, boolean)
instead.UseTopicPolicies.getMaxConsumersAsync(String)
instead.UseTopicPolicies.getMaxConsumersAsync(String, boolean)
instead.UseTopicPolicies.getMaxConsumersPerSubscription(String)
instead.UseTopicPolicies.getMaxMessageSize(String)
instead.UseTopicPolicies.getMaxMessageSizeAsync(String)
instead.UseTopicPolicies.getMaxProducers(String)
instead.UseTopicPolicies.getMaxProducers(String, boolean)
instead.UseTopicPolicies.getMaxProducersAsync(String)
instead.UseTopicPolicies.getMaxProducersAsync(String, boolean)
instead.UseTopicPolicies.getMaxSubscriptionsPerTopic(String)
instead.UsingTopics.getMessagesById(String, long, long)
instead.UsingTopics.getMessagesByIdAsync(String, long, long)
instead.UseTopicPolicies.getMessageTTL(String)
instead.UseTopicPolicies.getMessageTTL(String, boolean)
instead.UseTopicPolicies.getOffloadPolicies(String)
instead.UseTopicPolicies.getOffloadPolicies(String, boolean)
instead.UseTopicPolicies.getOffloadPoliciesAsync(String)
instead.UseTopicPolicies.getPersistence(String)
instead.UseTopicPolicies.getPersistence(String, boolean)
instead.UseTopicPolicies.getPersistenceAsync(String)
instead.UseTopicPolicies.getPersistenceAsync(String, boolean)
instead.UseTopicPolicies.getPublishRate(String)
instead.UseTopicPolicies.getPublishRateAsync(String)
instead.UseTopicPolicies.getReplicatorDispatchRate(String)
instead.UseTopicPolicies.getReplicatorDispatchRateAsync(String)
instead.UseTopicPolicies.getRetention(String)
instead.UseTopicPolicies.getRetention(String, boolean)
instead.UseTopicPolicies.getRetentionAsync(String)
instead.UseTopicPolicies.getRetentionAsync(String, boolean)
instead.UseTopicPolicies.getSubscribeRate(String)
instead.UseTopicPolicies.getSubscribeRate(String, boolean)
instead.UseTopicPolicies.getSubscribeRateAsync(String)
instead.UseTopicPolicies.getSubscribeRateAsync(String, boolean)
instead.UseTopicPolicies.getSubscriptionDispatchRate(String)
instead.UseTopicPolicies.getSubscriptionTypesEnabled(String)
instead.UseTopicPolicies.removeBacklogQuota(String)
instead.UseTopicPolicies.removeCompactionThreshold(String)
instead.UseTopicPolicies.removeCompactionThresholdAsync(String)
instead.UseTopicPolicies.removeDeduplicationStatus(String)
instead.UseTopicPolicies.removeDeduplicationStatusAsync(String)
instead.UseTopicPolicies.removeDelayedDeliveryPolicy(String)
instead.UseTopicPolicies.removeDispatchRate(String)
instead.UseTopicPolicies.removeDispatchRateAsync(String)
instead.UseTopicPolicies.removeInactiveTopicPolicies(String)
instead.UseTopicPolicies.removeMaxConsumers(String)
instead.UseTopicPolicies.removeMaxConsumersAsync(String)
instead.UseTopicPolicies.removeMaxMessageSize(String)
instead.UseTopicPolicies.removeMaxMessageSizeAsync(String)
instead.UseTopicPolicies.removeMaxProducers(String)
instead.UseTopicPolicies.removeMaxProducersAsync(String)
instead.UseTopicPolicies.removeMaxSubscriptionsPerTopic(String)
instead.UseTopicPolicies.removeMessageTTL(String)
instead.UseTopicPolicies.removeOffloadPolicies(String)
instead.UseTopicPolicies.removeOffloadPoliciesAsync(String)
instead.UseTopicPolicies.removePersistence(String)
instead.UseTopicPolicies.removePersistenceAsync(String)
instead.UseTopicPolicies.removePublishRate(String)
instead.UseTopicPolicies.removePublishRateAsync(String)
instead.UseTopicPolicies.removeReplicatorDispatchRate(String)
instead.UseTopicPolicies.removeRetention(String)
instead.UseTopicPolicies.removeRetentionAsync(String)
instead.UseTopicPolicies.removeSubscribeRate(String)
instead.UseTopicPolicies.removeSubscribeRateAsync(String)
instead.UseTopicPolicies.removeSubscriptionDispatchRate(String)
instead.UseTopicPolicies.removeSubscriptionTypesEnabled(String)
instead.UseTopicPolicies.setBacklogQuota(String, BacklogQuota)
instead.UseTopicPolicies.setCompactionThreshold(String, long)
instead.org.apache.pulsar.client.admin.Topics.setDelayedDeliveryPolicyAsync(String, DelayedDeliveryPolicies) UseTopicPolicies.setDispatchRate(String, DispatchRate)
instead.UseTopicPolicies.setMaxConsumers(String, int)
instead.UseTopicPolicies.setMaxConsumers(String, int)
instead.UseTopicPolicies.setMaxMessageSize(String, int)
instead.UseTopicPolicies.setMaxMessageSizeAsync(String, int)
instead.UseTopicPolicies.setMaxProducers(String, int)
instead.UseTopicPolicies.setMaxProducersAsync(String, int)
instead.UseTopicPolicies.setMessageTTL(String, int)
instead.UseTopicPolicies.setPersistence(String, PersistencePolicies)
(String)} instead.UseTopicPolicies.setPersistenceAsync(String, PersistencePolicies)
(String)} instead.UseTopicPolicies.setPublishRate(String, PublishRate)
instead.
Topics