You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/07/21 08:09:27 UTC
[pulsar] branch master updated: [fix][client] Add deprecated note to Topics interface. (#16692)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 4483df2b3d1 [fix][client] Add deprecated note to Topics interface. (#16692)
4483df2b3d1 is described below
commit 4483df2b3d113bfb55a8bb1a9e6c77160257c475
Author: Baodi Shi <wu...@icloud.com>
AuthorDate: Thu Jul 21 16:09:22 2022 +0800
[fix][client] Add deprecated note to Topics interface. (#16692)
---
.../org/apache/pulsar/client/admin/Topics.java | 177 +++++++++++++++++++++
1 file changed, 177 insertions(+)
diff --git a/pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java b/pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java
index 8f6f50445d8..71ca31e5903 100644
--- a/pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java
+++ b/pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java
@@ -2031,6 +2031,7 @@ public interface Topics {
* Topic does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getBacklogQuotaMap(String)} instead.
*/
@Deprecated
Map<BacklogQuota.BacklogQuotaType, BacklogQuota> getBacklogQuotaMap(String topic)
@@ -2042,6 +2043,7 @@ public interface Topics {
* @param applied
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getBacklogQuotaMap(String, boolean)} instead.
*/
@Deprecated
Map<BacklogQuota.BacklogQuotaType, BacklogQuota> getBacklogQuotaMap(String topic, boolean applied)
@@ -2098,11 +2100,16 @@ public interface Topics {
* Topic does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setBacklogQuota(String, BacklogQuota, BacklogQuota.BacklogQuotaType)}
+ * instead.
*/
@Deprecated
void setBacklogQuota(String topic, BacklogQuota backlogQuota,
BacklogQuota.BacklogQuotaType backlogQuotaType) throws PulsarAdminException;
+ /**
+ * @deprecated Use {@link TopicPolicies#setBacklogQuota(String, BacklogQuota)} instead.
+ */
@Deprecated
default void setBacklogQuota(String topic, BacklogQuota backlogQuota) throws PulsarAdminException {
setBacklogQuota(topic, backlogQuota, BacklogQuota.BacklogQuotaType.destination_storage);
@@ -2122,10 +2129,14 @@ public interface Topics {
* Topic does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeBacklogQuota(String, BacklogQuota.BacklogQuotaType)} instead.
*/
@Deprecated
void removeBacklogQuota(String topic, BacklogQuota.BacklogQuotaType backlogQuotaType) throws PulsarAdminException;
+ /**
+ * @deprecated Use {@link TopicPolicies#removeBacklogQuota(String)} instead.
+ */
@Deprecated
default void removeBacklogQuota(String topic)
throws PulsarAdminException {
@@ -2138,6 +2149,7 @@ public interface Topics {
* @param applied
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getDelayedDeliveryPolicy(String, boolean)} instead.
*/
@Deprecated
DelayedDeliveryPolicies getDelayedDeliveryPolicy(String topic
@@ -2148,6 +2160,7 @@ public interface Topics {
* @param topic
* @param applied
* @return
+ * @deprecated Use {@link TopicPolicies#getDelayedDeliveryPolicyAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<DelayedDeliveryPolicies> getDelayedDeliveryPolicyAsync(String topic
@@ -2157,6 +2170,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getDelayedDeliveryPolicy(String)} instead.
*/
@Deprecated
DelayedDeliveryPolicies getDelayedDeliveryPolicy(String topic) throws PulsarAdminException;
@@ -2165,6 +2179,7 @@ public interface Topics {
* Get the delayed delivery policy for a specified topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getDelayedDeliveryPolicyAsync(String)} instead.
*/
@Deprecated
CompletableFuture<DelayedDeliveryPolicies> getDelayedDeliveryPolicyAsync(String topic);
@@ -2174,6 +2189,7 @@ public interface Topics {
* @param topic
* @param delayedDeliveryPolicies
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#setDelayedDeliveryPolicy(String, DelayedDeliveryPolicies)} instead.
*/
@Deprecated
void setDelayedDeliveryPolicy(String topic
@@ -2184,6 +2200,7 @@ public interface Topics {
* @param topic
* @param delayedDeliveryPolicies
* @return
+ * @deprecated Use {@link TopicPolicies#setDelayedDeliveryPolicyAsync(String, DelayedDeliveryPolicies)} instead.
*/
@Deprecated
CompletableFuture<Void> setDelayedDeliveryPolicyAsync(String topic
@@ -2193,6 +2210,7 @@ public interface Topics {
* Remove the delayed delivery policy for a specified topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#removeDelayedDeliveryPolicyAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeDelayedDeliveryPolicyAsync(String topic);
@@ -2201,6 +2219,7 @@ public interface Topics {
* Remove the delayed delivery policy for a specified topic.
* @param topic
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#removeDelayedDeliveryPolicy(String)} instead.
*/
@Deprecated
void removeDelayedDeliveryPolicy(String topic) throws PulsarAdminException;
@@ -2218,6 +2237,7 @@ public interface Topics {
* Topic does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMessageTTL(String, int)} instead.
*/
@Deprecated
void setMessageTTL(String topic, int messageTTLInSecond) throws PulsarAdminException;
@@ -2233,6 +2253,7 @@ public interface Topics {
* Topic does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMessageTTL(String)} instead.
*/
@Deprecated
Integer getMessageTTL(String topic) throws PulsarAdminException;
@@ -2242,6 +2263,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getMessageTTL(String, boolean)} instead.
*/
@Deprecated
Integer getMessageTTL(String topic, boolean applied) throws PulsarAdminException;
@@ -2256,6 +2278,7 @@ public interface Topics {
* Topic does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeMessageTTL(String)} instead.
*/
@Deprecated
void removeMessageTTL(String topic) throws PulsarAdminException;
@@ -2288,6 +2311,7 @@ public interface Topics {
* Concurrent modification
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setRetention(String, RetentionPolicies)} instead.
*/
@Deprecated
void setRetention(String topic, RetentionPolicies retention) throws PulsarAdminException;
@@ -2311,6 +2335,7 @@ public interface Topics {
*
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#setRetentionAsync(String, RetentionPolicies)} instead.
*/
@Deprecated
CompletableFuture<Void> setRetentionAsync(String topic, RetentionPolicies retention);
@@ -2342,6 +2367,7 @@ public interface Topics {
* Concurrent modification
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getRetention(String)} instead.
*/
@Deprecated
RetentionPolicies getRetention(String topic) throws PulsarAdminException;
@@ -2354,6 +2380,7 @@ public interface Topics {
*
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#getRetentionAsync(String)} instead.
*/
@Deprecated
CompletableFuture<RetentionPolicies> getRetentionAsync(String topic);
@@ -2364,6 +2391,7 @@ public interface Topics {
* @param applied
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getRetention(String, boolean)} instead.
*/
@Deprecated
RetentionPolicies getRetention(String topic, boolean applied) throws PulsarAdminException;
@@ -2373,6 +2401,7 @@ public interface Topics {
* @param topic
* @param applied
* @return
+ * @deprecated Use {@link TopicPolicies#getRetentionAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<RetentionPolicies> getRetentionAsync(String topic, boolean applied);
@@ -2396,6 +2425,7 @@ public interface Topics {
* Concurrent modification
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeRetention(String)} instead.
*/
@Deprecated
void removeRetention(String topic) throws PulsarAdminException;
@@ -2419,6 +2449,7 @@ public interface Topics {
*
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#removeRetentionAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeRetentionAsync(String topic);
@@ -2428,6 +2459,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getMaxUnackedMessagesOnConsumer(String)} instead.
*/
@Deprecated
Integer getMaxUnackedMessagesOnConsumer(String topic) throws PulsarAdminException;
@@ -2436,6 +2468,7 @@ public interface Topics {
* get max unacked messages on consumer of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getMaxUnackedMessagesOnConsumerAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxUnackedMessagesOnConsumerAsync(String topic);
@@ -2446,6 +2479,7 @@ public interface Topics {
* @param applied
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getMaxUnackedMessagesOnConsumer(String, boolean)} instead.
*/
@Deprecated
Integer getMaxUnackedMessagesOnConsumer(String topic, boolean applied) throws PulsarAdminException;
@@ -2455,6 +2489,7 @@ public interface Topics {
* @param topic
* @param applied
* @return
+ * @deprecated Use {@link TopicPolicies#getMaxUnackedMessagesOnConsumerAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxUnackedMessagesOnConsumerAsync(String topic, boolean applied);
@@ -2464,6 +2499,7 @@ public interface Topics {
* @param topic
* @param maxNum
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#setMaxUnackedMessagesOnConsumer(String, int)} instead.
*/
@Deprecated
void setMaxUnackedMessagesOnConsumer(String topic, int maxNum) throws PulsarAdminException;
@@ -2473,6 +2509,7 @@ public interface Topics {
* @param topic
* @param maxNum
* @return
+ * @deprecated Use {@link TopicPolicies#setMaxUnackedMessagesOnConsumerAsync(String, int)} instead.
*/
@Deprecated
CompletableFuture<Void> setMaxUnackedMessagesOnConsumerAsync(String topic, int maxNum);
@@ -2481,6 +2518,7 @@ public interface Topics {
* remove max unacked messages on consumer of a topic.
* @param topic
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#removeMaxUnackedMessagesOnConsumer(String)} instead.
*/
@Deprecated
void removeMaxUnackedMessagesOnConsumer(String topic) throws PulsarAdminException;
@@ -2489,6 +2527,7 @@ public interface Topics {
* remove max unacked messages on consumer of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#removeMaxUnackedMessagesOnConsumerAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeMaxUnackedMessagesOnConsumerAsync(String topic);
@@ -2498,6 +2537,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getInactiveTopicPolicies(String, boolean)} instead.
*/
@Deprecated
InactiveTopicPolicies getInactiveTopicPolicies(String topic, boolean applied) throws PulsarAdminException;
@@ -2507,6 +2547,7 @@ public interface Topics {
* @param topic
* @param applied
* @return
+ * @deprecated Use {@link TopicPolicies#getInactiveTopicPoliciesAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<InactiveTopicPolicies> getInactiveTopicPoliciesAsync(String topic, boolean applied);
@@ -2515,6 +2556,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getInactiveTopicPolicies(String)} instead.
*/
@Deprecated
InactiveTopicPolicies getInactiveTopicPolicies(String topic) throws PulsarAdminException;
@@ -2523,6 +2565,7 @@ public interface Topics {
* get inactive topic policies of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getInactiveTopicPoliciesAsync(String)} instead.
*/
@Deprecated
CompletableFuture<InactiveTopicPolicies> getInactiveTopicPoliciesAsync(String topic);
@@ -2532,6 +2575,7 @@ public interface Topics {
* @param topic
* @param inactiveTopicPolicies
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#setInactiveTopicPolicies(String, InactiveTopicPolicies)} instead.
*/
@Deprecated
void setInactiveTopicPolicies(String topic
@@ -2542,6 +2586,7 @@ public interface Topics {
* @param topic
* @param inactiveTopicPolicies
* @return
+ * @deprecated Use {@link TopicPolicies#setInactiveTopicPoliciesAsync(String, InactiveTopicPolicies)} instead.
*/
@Deprecated
CompletableFuture<Void> setInactiveTopicPoliciesAsync(String topic, InactiveTopicPolicies inactiveTopicPolicies);
@@ -2550,6 +2595,7 @@ public interface Topics {
* remove inactive topic policies of a topic.
* @param topic
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#removeInactiveTopicPolicies(String)} instead.
*/
@Deprecated
void removeInactiveTopicPolicies(String topic) throws PulsarAdminException;
@@ -2558,6 +2604,7 @@ public interface Topics {
* remove inactive topic policies of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#removeInactiveTopicPoliciesAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeInactiveTopicPoliciesAsync(String topic);
@@ -2567,6 +2614,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getOffloadPolicies(String)} instead.
*/
@Deprecated
OffloadPolicies getOffloadPolicies(String topic) throws PulsarAdminException;
@@ -2575,6 +2623,7 @@ public interface Topics {
* get offload policies of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getOffloadPoliciesAsync(String)} instead.
*/
@Deprecated
CompletableFuture<OffloadPolicies> getOffloadPoliciesAsync(String topic);
@@ -2584,6 +2633,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getOffloadPolicies(String, boolean)} instead.
*/
@Deprecated
OffloadPolicies getOffloadPolicies(String topic, boolean applied) throws PulsarAdminException;
@@ -2592,6 +2642,7 @@ public interface Topics {
* get applied offload policies of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getOffloadPoliciesAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<OffloadPolicies> getOffloadPoliciesAsync(String topic, boolean applied);
@@ -2601,6 +2652,7 @@ public interface Topics {
* @param topic
* @param offloadPolicies
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#setOffloadPolicies(String, OffloadPolicies)} instead.
*/
@Deprecated
void setOffloadPolicies(String topic, OffloadPolicies offloadPolicies) throws PulsarAdminException;
@@ -2610,6 +2662,7 @@ public interface Topics {
* @param topic
* @param offloadPolicies
* @return
+ * @deprecated Use {@link TopicPolicies#setOffloadPoliciesAsync(String, OffloadPolicies)} instead.
*/
@Deprecated
CompletableFuture<Void> setOffloadPoliciesAsync(String topic, OffloadPolicies offloadPolicies);
@@ -2618,6 +2671,7 @@ public interface Topics {
* remove offload policies of a topic.
* @param topic
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#removeOffloadPolicies(String)} instead.
*/
@Deprecated
void removeOffloadPolicies(String topic) throws PulsarAdminException;
@@ -2626,6 +2680,7 @@ public interface Topics {
* remove offload policies of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#removeOffloadPoliciesAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeOffloadPoliciesAsync(String topic);
@@ -2635,6 +2690,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getMaxUnackedMessagesOnSubscription(String)} instead.
*/
@Deprecated
Integer getMaxUnackedMessagesOnSubscription(String topic) throws PulsarAdminException;
@@ -2643,6 +2699,7 @@ public interface Topics {
* get max unacked messages on subscription of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getMaxUnackedMessagesOnSubscriptionAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxUnackedMessagesOnSubscriptionAsync(String topic);
@@ -2652,6 +2709,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getMaxUnackedMessagesOnSubscriptionAsync(String, boolean)} instead.
*/
@Deprecated
Integer getMaxUnackedMessagesOnSubscription(String topic, boolean applied) throws PulsarAdminException;
@@ -2660,6 +2718,7 @@ public interface Topics {
* get max unacked messages on subscription of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getMaxUnackedMessagesOnSubscriptionAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxUnackedMessagesOnSubscriptionAsync(String topic, boolean applied);
@@ -2669,6 +2728,7 @@ public interface Topics {
* @param topic
* @param maxNum
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#setMaxUnackedMessagesOnSubscription(String, int)} instead.
*/
@Deprecated
void setMaxUnackedMessagesOnSubscription(String topic, int maxNum) throws PulsarAdminException;
@@ -2678,6 +2738,7 @@ public interface Topics {
* @param topic
* @param maxNum
* @return
+ * @deprecated Use {@link TopicPolicies#setMaxUnackedMessagesOnSubscriptionAsync(String, int)} instead.
*/
@Deprecated
CompletableFuture<Void> setMaxUnackedMessagesOnSubscriptionAsync(String topic, int maxNum);
@@ -2686,6 +2747,7 @@ public interface Topics {
* remove max unacked messages on subscription of a topic.
* @param topic
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#removeMaxUnackedMessagesOnSubscription(String)} instead.
*/
@Deprecated
void removeMaxUnackedMessagesOnSubscription(String topic) throws PulsarAdminException;
@@ -2694,6 +2756,7 @@ public interface Topics {
* remove max unacked messages on subscription of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#removeMaxUnackedMessagesOnSubscriptionAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeMaxUnackedMessagesOnSubscriptionAsync(String topic);
@@ -2704,6 +2767,7 @@ public interface Topics {
* @param topic Topic name
* @param persistencePolicies Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setPersistence(String, PersistencePolicies)} (String)} instead.
*/
@Deprecated
void setPersistence(String topic, PersistencePolicies persistencePolicies) throws PulsarAdminException;
@@ -2713,6 +2777,7 @@ public interface Topics {
*
* @param topic Topic name
* @param persistencePolicies Configuration of bookkeeper persistence policies
+ * @deprecated Use {@link TopicPolicies#setPersistenceAsync(String, PersistencePolicies)} (String)} instead.
*/
@Deprecated
CompletableFuture<Void> setPersistenceAsync(String topic, PersistencePolicies persistencePolicies);
@@ -2723,6 +2788,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getPersistence(String)} instead.
*/
@Deprecated
PersistencePolicies getPersistence(String topic) throws PulsarAdminException;
@@ -2731,6 +2797,7 @@ public interface Topics {
* Get the configuration of persistence policies for specified topic asynchronously.
*
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#getPersistenceAsync(String)} instead.
*/
@Deprecated
CompletableFuture<PersistencePolicies> getPersistenceAsync(String topic);
@@ -2741,6 +2808,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getPersistence(String, boolean)} instead.
*/
@Deprecated
PersistencePolicies getPersistence(String topic, boolean applied) throws PulsarAdminException;
@@ -2749,6 +2817,7 @@ public interface Topics {
* Get the applied configuration of persistence policies for specified topic asynchronously.
*
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#getPersistenceAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<PersistencePolicies> getPersistenceAsync(String topic, boolean applied);
@@ -2758,6 +2827,7 @@ public interface Topics {
*
* @param topic Topic name
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#removePersistence(String)} instead.
*/
@Deprecated
void removePersistence(String topic) throws PulsarAdminException;
@@ -2766,6 +2836,7 @@ public interface Topics {
* Remove the configuration of persistence policies for specified topic asynchronously.
*
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#removePersistenceAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removePersistenceAsync(String topic);
@@ -2775,6 +2846,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getDeduplicationStatus(String)} instead.
*/
@Deprecated
Boolean getDeduplicationEnabled(String topic) throws PulsarAdminException;
@@ -2783,6 +2855,7 @@ public interface Topics {
* get deduplication enabled of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getDeduplicationStatusAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Boolean> getDeduplicationEnabledAsync(String topic);
@@ -2792,6 +2865,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getDeduplicationStatus(String)} instead.
*/
@Deprecated
Boolean getDeduplicationStatus(String topic) throws PulsarAdminException;
@@ -2800,6 +2874,7 @@ public interface Topics {
* get deduplication enabled of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getDeduplicationStatusAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Boolean> getDeduplicationStatusAsync(String topic);
@@ -2808,6 +2883,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getDeduplicationStatus(String, boolean)} instead.
*/
@Deprecated
Boolean getDeduplicationStatus(String topic, boolean applied) throws PulsarAdminException;
@@ -2816,6 +2892,7 @@ public interface Topics {
* get applied deduplication enabled of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getDeduplicationStatusAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<Boolean> getDeduplicationStatusAsync(String topic, boolean applied);
@@ -2825,6 +2902,7 @@ public interface Topics {
* @param topic
* @param enabled
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#setDeduplicationStatus(String, boolean)} instead.
*/
@Deprecated
void enableDeduplication(String topic, boolean enabled) throws PulsarAdminException;
@@ -2834,6 +2912,7 @@ public interface Topics {
* @param topic
* @param enabled
* @return
+ * @deprecated Use {@link TopicPolicies#setDeduplicationStatusAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<Void> enableDeduplicationAsync(String topic, boolean enabled);
@@ -2843,6 +2922,7 @@ public interface Topics {
* @param topic
* @param enabled
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#setDeduplicationStatus(String, boolean)} instead.
*/
@Deprecated
void setDeduplicationStatus(String topic, boolean enabled) throws PulsarAdminException;
@@ -2852,6 +2932,7 @@ public interface Topics {
* @param topic
* @param enabled
* @return
+ * @deprecated Use {@link TopicPolicies#setDeduplicationStatusAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<Void> setDeduplicationStatusAsync(String topic, boolean enabled);
@@ -2860,6 +2941,7 @@ public interface Topics {
* remove deduplication enabled of a topic.
* @param topic
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#removeDeduplicationStatus(String)} instead.
*/
@Deprecated
void disableDeduplication(String topic) throws PulsarAdminException;
@@ -2868,6 +2950,7 @@ public interface Topics {
* remove deduplication enabled of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#removeDeduplicationStatusAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> disableDeduplicationAsync(String topic);
@@ -2876,6 +2959,7 @@ public interface Topics {
* remove deduplication enabled of a topic.
* @param topic
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#removeDeduplicationStatus(String)} instead.
*/
@Deprecated
void removeDeduplicationStatus(String topic) throws PulsarAdminException;
@@ -2884,6 +2968,7 @@ public interface Topics {
* remove deduplication enabled of a topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#removeDeduplicationStatusAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeDeduplicationStatusAsync(String topic);
@@ -2896,6 +2981,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setDispatchRate(String, DispatchRate)} instead.
*/
@Deprecated
void setDispatchRate(String topic, DispatchRate dispatchRate) throws PulsarAdminException;
@@ -2908,6 +2994,7 @@ public interface Topics {
* @param topic
* @param dispatchRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#setDispatchRateAsync(String, DispatchRate)} instead.
*/
@Deprecated
CompletableFuture<Void> setDispatchRateAsync(String topic, DispatchRate dispatchRate);
@@ -2920,6 +3007,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getDispatchRate(String)} instead.
*/
@Deprecated
DispatchRate getDispatchRate(String topic) throws PulsarAdminException;
@@ -2932,6 +3020,7 @@ public interface Topics {
* @param topic
* @returns messageRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#getDispatchRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<DispatchRate> getDispatchRateAsync(String topic);
@@ -2944,6 +3033,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getDispatchRate(String, boolean)} instead.
*/
@Deprecated
DispatchRate getDispatchRate(String topic, boolean applied) throws PulsarAdminException;
@@ -2956,6 +3046,7 @@ public interface Topics {
* @param topic
* @returns messageRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#getDispatchRateAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<DispatchRate> getDispatchRateAsync(String topic, boolean applied);
@@ -2968,6 +3059,7 @@ public interface Topics {
* @param topic
* @throws PulsarAdminException
* unexpected error
+ * @deprecated Use {@link TopicPolicies#removeDispatchRate(String)} instead.
*/
@Deprecated
void removeDispatchRate(String topic) throws PulsarAdminException;
@@ -2980,6 +3072,7 @@ public interface Topics {
* @param topic
* @throws PulsarAdminException
* unexpected error
+ * @deprecated Use {@link TopicPolicies#removeDispatchRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeDispatchRateAsync(String topic) throws PulsarAdminException;
@@ -2994,6 +3087,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setSubscriptionDispatchRate(String, DispatchRate)} instead.
*/
@Deprecated
void setSubscriptionDispatchRate(String topic, DispatchRate dispatchRate) throws PulsarAdminException;
@@ -3006,6 +3100,7 @@ public interface Topics {
* @param topic
* @param dispatchRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#setSubscriptionDispatchRateAsync(String, DispatchRate)} instead.
*/
@Deprecated
CompletableFuture<Void> setSubscriptionDispatchRateAsync(String topic, DispatchRate dispatchRate);
@@ -3020,6 +3115,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getSubscriptionDispatchRate(String, boolean)} instead.
*/
@Deprecated
DispatchRate getSubscriptionDispatchRate(String namespace, boolean applied) throws PulsarAdminException;
@@ -3032,6 +3128,7 @@ public interface Topics {
* @param namespace
* @returns DispatchRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#getSubscriptionDispatchRateAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<DispatchRate> getSubscriptionDispatchRateAsync(String namespace, boolean applied);
@@ -3046,6 +3143,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getSubscriptionDispatchRate(String)} instead.
*/
@Deprecated
DispatchRate getSubscriptionDispatchRate(String topic) throws PulsarAdminException;
@@ -3058,6 +3156,7 @@ public interface Topics {
* @param topic
* @returns DispatchRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#getSubscriptionDispatchRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<DispatchRate> getSubscriptionDispatchRateAsync(String topic);
@@ -3068,6 +3167,7 @@ public interface Topics {
* Topic name
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeSubscriptionDispatchRate(String)} instead.
*/
@Deprecated
void removeSubscriptionDispatchRate(String topic) throws PulsarAdminException;
@@ -3076,6 +3176,7 @@ public interface Topics {
* Remove subscription-message-dispatch-rate for a topic asynchronously.
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#removeSubscriptionDispatchRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeSubscriptionDispatchRateAsync(String topic);
@@ -3090,6 +3191,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setReplicatorDispatchRate(String, DispatchRate)} instead.
*/
@Deprecated
void setReplicatorDispatchRate(String topic, DispatchRate dispatchRate) throws PulsarAdminException;
@@ -3102,6 +3204,7 @@ public interface Topics {
* @param topic
* @param dispatchRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#setReplicatorDispatchRateAsync(String, DispatchRate)} instead.
*/
@Deprecated
CompletableFuture<Void> setReplicatorDispatchRateAsync(String topic, DispatchRate dispatchRate);
@@ -3116,6 +3219,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getReplicatorDispatchRate(String)} instead.
*/
@Deprecated
DispatchRate getReplicatorDispatchRate(String topic) throws PulsarAdminException;
@@ -3128,6 +3232,7 @@ public interface Topics {
* @param topic
* @returns DispatchRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#getReplicatorDispatchRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<DispatchRate> getReplicatorDispatchRateAsync(String topic);
@@ -3138,6 +3243,7 @@ public interface Topics {
* @param applied
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getReplicatorDispatchRate(String, boolean)} instead.
*/
@Deprecated
DispatchRate getReplicatorDispatchRate(String topic, boolean applied) throws PulsarAdminException;
@@ -3147,6 +3253,7 @@ public interface Topics {
* @param topic
* @param applied
* @return
+ * @deprecated Use {@link TopicPolicies#getReplicatorDispatchRateAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<DispatchRate> getReplicatorDispatchRateAsync(String topic, boolean applied);
@@ -3157,6 +3264,7 @@ public interface Topics {
* Topic name
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeReplicatorDispatchRate(String)} instead.
*/
@Deprecated
void removeReplicatorDispatchRate(String topic) throws PulsarAdminException;
@@ -3165,6 +3273,7 @@ public interface Topics {
* Remove replicatorDispatchRate for a topic asynchronously.
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#removeReplicatorDispatchRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeReplicatorDispatchRateAsync(String topic);
@@ -3188,6 +3297,7 @@ public interface Topics {
* Namespace does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getCompactionThreshold(String)} instead.
*/
@Deprecated
Long getCompactionThreshold(String topic) throws PulsarAdminException;
@@ -3204,6 +3314,7 @@ public interface Topics {
*
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#getCompactionThresholdAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Long> getCompactionThresholdAsync(String topic);
@@ -3215,6 +3326,7 @@ public interface Topics {
* @throws NotAuthorizedException Don't have admin permission
* @throws NotFoundException Namespace does not exist
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getCompactionThreshold(String, boolean)} instead.
*/
@Deprecated
Long getCompactionThreshold(String topic, boolean applied) throws PulsarAdminException;
@@ -3223,6 +3335,7 @@ public interface Topics {
* Get the compactionThreshold for a topic asynchronously. The maximum number of bytes
* can have before compaction is triggered. 0 disables.
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#getCompactionThreshold(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<Long> getCompactionThresholdAsync(String topic, boolean applied);
@@ -3248,6 +3361,7 @@ public interface Topics {
* Namespace does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setCompactionThreshold(String, long)} instead.
*/
@Deprecated
void setCompactionThreshold(String topic, long compactionThreshold) throws PulsarAdminException;
@@ -3266,6 +3380,7 @@ public interface Topics {
* Topic name
* @param compactionThreshold
* maximum number of backlog bytes before compaction is triggered
+ * @deprecated Use {@link TopicPolicies#setCompactionThresholdAsync(String, long)} instead.
*/
@Deprecated
CompletableFuture<Void> setCompactionThresholdAsync(String topic, long compactionThreshold);
@@ -3276,6 +3391,7 @@ public interface Topics {
* Topic name
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeCompactionThreshold(String)} instead.
*/
@Deprecated
void removeCompactionThreshold(String topic) throws PulsarAdminException;
@@ -3284,6 +3400,7 @@ public interface Topics {
* Remove the compactionThreshold for a topic asynchronously.
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#removeCompactionThresholdAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeCompactionThresholdAsync(String topic);
@@ -3296,6 +3413,7 @@ public interface Topics {
* number of messages per second
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setPublishRate(String, PublishRate)} instead.
*/
@Deprecated
void setPublishRate(String topic, PublishRate publishMsgRate) throws PulsarAdminException;
@@ -3306,6 +3424,7 @@ public interface Topics {
* @param topic
* @param publishMsgRate
* number of messages per second
+ * @deprecated Use {@link TopicPolicies#setPublishRateAsync(String, PublishRate)} instead.
*/
@Deprecated
CompletableFuture<Void> setPublishRateAsync(String topic, PublishRate publishMsgRate);
@@ -3316,6 +3435,7 @@ public interface Topics {
* @param topic
* @return number of messages per second
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getPublishRate(String)} instead.
*/
@Deprecated
PublishRate getPublishRate(String topic) throws PulsarAdminException;
@@ -3325,6 +3445,7 @@ public interface Topics {
*
* @param topic
* @return number of messages per second
+ * @deprecated Use {@link TopicPolicies#getPublishRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<PublishRate> getPublishRateAsync(String topic);
@@ -3337,6 +3458,7 @@ public interface Topics {
* @param topic
* @throws PulsarAdminException
* unexpected error
+ * @deprecated Use {@link TopicPolicies#removePublishRate(String)} instead.
*/
@Deprecated
void removePublishRate(String topic) throws PulsarAdminException;
@@ -3349,6 +3471,7 @@ public interface Topics {
* @param topic
* @throws PulsarAdminException
* unexpected error
+ * @deprecated Use {@link TopicPolicies#removePublishRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removePublishRateAsync(String topic) throws PulsarAdminException;
@@ -3371,6 +3494,7 @@ public interface Topics {
* Namespace does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxConsumersPerSubscription(String)} instead.
*/
@Deprecated
Integer getMaxConsumersPerSubscription(String topic) throws PulsarAdminException;
@@ -3386,6 +3510,7 @@ public interface Topics {
*
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#getMaxConsumersPerSubscriptionAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxConsumersPerSubscriptionAsync(String topic);
@@ -3410,6 +3535,7 @@ public interface Topics {
* Namespace does not exist
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxConsumersPerSubscription(String, int)} instead.
*/
@Deprecated
void setMaxConsumersPerSubscription(String topic, int maxConsumersPerSubscription) throws PulsarAdminException;
@@ -3427,6 +3553,7 @@ public interface Topics {
* Topic name
* @param maxConsumersPerSubscription
* maxConsumersPerSubscription value for a namespace
+ * @deprecated Use {@link TopicPolicies#setMaxConsumersPerSubscriptionAsync(String, int)} instead.
*/
@Deprecated
CompletableFuture<Void> setMaxConsumersPerSubscriptionAsync(String topic, int maxConsumersPerSubscription);
@@ -3437,6 +3564,7 @@ public interface Topics {
* Topic name
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeMaxConsumersPerSubscription(String)} instead.
*/
@Deprecated
void removeMaxConsumersPerSubscription(String topic) throws PulsarAdminException;
@@ -3445,6 +3573,7 @@ public interface Topics {
* Remove the maxConsumersPerSubscription for a topic asynchronously.
* @param topic
* Topic name
+ * @deprecated Use {@link TopicPolicies#removeMaxConsumersPerSubscriptionAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeMaxConsumersPerSubscriptionAsync(String topic);
@@ -3455,6 +3584,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxProducers(String)} instead.
*/
@Deprecated
Integer getMaxProducers(String topic) throws PulsarAdminException;
@@ -3465,6 +3595,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxProducersAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxProducersAsync(String topic);
@@ -3475,6 +3606,7 @@ public interface Topics {
* @param applied
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getMaxProducers(String, boolean)} instead.
*/
@Deprecated
Integer getMaxProducers(String topic, boolean applied) throws PulsarAdminException;
@@ -3484,6 +3616,7 @@ public interface Topics {
* @param topic
* @param applied
* @return
+ * @deprecated Use {@link TopicPolicies#getMaxProducersAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxProducersAsync(String topic, boolean applied);
@@ -3495,6 +3628,7 @@ public interface Topics {
* @param topic Topic name
* @param maxProducers Max number of producer
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxProducers(String, int)} instead.
*/
@Deprecated
void setMaxProducers(String topic, int maxProducers) throws PulsarAdminException;
@@ -3505,6 +3639,7 @@ public interface Topics {
* @param topic Topic name
* @param maxProducers Max number of producer
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxProducersAsync(String, int)} instead.
*/
@Deprecated
CompletableFuture<Void> setMaxProducersAsync(String topic, int maxProducers);
@@ -3514,6 +3649,7 @@ public interface Topics {
*
* @param topic Topic name
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeMaxProducers(String)} instead.
*/
@Deprecated
void removeMaxProducers(String topic) throws PulsarAdminException;
@@ -3522,6 +3658,7 @@ public interface Topics {
* Remove the max number of producer for specified topic asynchronously.
*
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#removeMaxProducersAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeMaxProducersAsync(String topic);
@@ -3532,6 +3669,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxSubscriptionsPerTopic(String)} instead.
*/
@Deprecated
Integer getMaxSubscriptionsPerTopic(String topic) throws PulsarAdminException;
@@ -3542,6 +3680,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxSubscriptionsPerTopicAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxSubscriptionsPerTopicAsync(String topic);
@@ -3553,6 +3692,7 @@ public interface Topics {
* @param topic Topic name
* @param maxSubscriptionsPerTopic Max number of subscriptions
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxSubscriptionsPerTopic(String, int)} instead.
*/
@Deprecated
void setMaxSubscriptionsPerTopic(String topic, int maxSubscriptionsPerTopic) throws PulsarAdminException;
@@ -3563,6 +3703,7 @@ public interface Topics {
* @param topic Topic name
* @param maxSubscriptionsPerTopic Max number of subscriptions
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxSubscriptionsPerTopicAsync(String, int)} instead.
*/
@Deprecated
CompletableFuture<Void> setMaxSubscriptionsPerTopicAsync(String topic, int maxSubscriptionsPerTopic);
@@ -3572,6 +3713,7 @@ public interface Topics {
*
* @param topic Topic name
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeMaxSubscriptionsPerTopic(String)} instead.
*/
@Deprecated
void removeMaxSubscriptionsPerTopic(String topic) throws PulsarAdminException;
@@ -3580,6 +3722,7 @@ public interface Topics {
* Remove the max number of subscriptions for specified topic asynchronously.
*
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#removeMaxSubscriptionsPerTopicAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeMaxSubscriptionsPerTopicAsync(String topic);
@@ -3590,6 +3733,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxMessageSize(String)} instead.
*/
@Deprecated
Integer getMaxMessageSize(String topic) throws PulsarAdminException;
@@ -3600,6 +3744,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxMessageSizeAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxMessageSizeAsync(String topic);
@@ -3611,6 +3756,7 @@ public interface Topics {
* @param topic Topic name
* @param maxMessageSize Max message size of producer
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxMessageSize(String, int)} instead.
*/
@Deprecated
void setMaxMessageSize(String topic, int maxMessageSize) throws PulsarAdminException;
@@ -3621,6 +3767,7 @@ public interface Topics {
* @param topic Topic name
* @param maxMessageSize Max message size of topic
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxMessageSizeAsync(String, int)} instead.
*/
@Deprecated
CompletableFuture<Void> setMaxMessageSizeAsync(String topic, int maxMessageSize);
@@ -3630,6 +3777,7 @@ public interface Topics {
*
* @param topic Topic name
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeMaxMessageSize(String)} instead.
*/
@Deprecated
void removeMaxMessageSize(String topic) throws PulsarAdminException;
@@ -3638,6 +3786,7 @@ public interface Topics {
* Remove the max message size for specified topic asynchronously.
*
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#removeMaxMessageSizeAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeMaxMessageSizeAsync(String topic);
@@ -3648,6 +3797,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxConsumers(String)} instead.
*/
@Deprecated
Integer getMaxConsumers(String topic) throws PulsarAdminException;
@@ -3658,6 +3808,7 @@ public interface Topics {
* @param topic Topic name
* @return Configuration of bookkeeper persistence policies
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#getMaxConsumersAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxConsumersAsync(String topic);
@@ -3668,6 +3819,7 @@ public interface Topics {
* @param applied
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getMaxConsumers(String, boolean)} instead.
*/
@Deprecated
Integer getMaxConsumers(String topic, boolean applied) throws PulsarAdminException;
@@ -3677,6 +3829,7 @@ public interface Topics {
* @param topic
* @param applied
* @return
+ * @deprecated Use {@link TopicPolicies#getMaxConsumersAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<Integer> getMaxConsumersAsync(String topic, boolean applied);
@@ -3687,6 +3840,7 @@ public interface Topics {
* @param topic Topic name
* @param maxConsumers Max number of consumer
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxConsumers(String, int)} instead.
*/
@Deprecated
void setMaxConsumers(String topic, int maxConsumers) throws PulsarAdminException;
@@ -3697,6 +3851,7 @@ public interface Topics {
* @param topic Topic name
* @param maxConsumers Max number of consumer
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#setMaxConsumers(String, int)} instead.
*/
@Deprecated
CompletableFuture<Void> setMaxConsumersAsync(String topic, int maxConsumers);
@@ -3706,6 +3861,7 @@ public interface Topics {
*
* @param topic Topic name
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeMaxConsumers(String)} instead.
*/
@Deprecated
void removeMaxConsumers(String topic) throws PulsarAdminException;
@@ -3714,6 +3870,7 @@ public interface Topics {
* Remove the max number of consumer for specified topic asynchronously.
*
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#removeMaxConsumersAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeMaxConsumersAsync(String topic);
@@ -3723,6 +3880,7 @@ public interface Topics {
* @param topic
* @return
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#getDeduplicationSnapshotInterval(String)} instead.
*/
@Deprecated
Integer getDeduplicationSnapshotInterval(String topic) throws PulsarAdminException;
@@ -3731,6 +3889,7 @@ public interface Topics {
* Get the deduplication snapshot interval for specified topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#getDeduplicationSnapshotIntervalAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Integer> getDeduplicationSnapshotIntervalAsync(String topic);
@@ -3740,6 +3899,7 @@ public interface Topics {
* @param topic
* @param interval
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#setDeduplicationSnapshotInterval(String, int)} instead.
*/
@Deprecated
void setDeduplicationSnapshotInterval(String topic, int interval) throws PulsarAdminException;
@@ -3749,6 +3909,7 @@ public interface Topics {
* @param topic
* @param interval
* @return
+ * @deprecated Use {@link TopicPolicies#setDeduplicationSnapshotIntervalAsync(String, int)} instead.
*/
@Deprecated
CompletableFuture<Void> setDeduplicationSnapshotIntervalAsync(String topic, int interval);
@@ -3757,6 +3918,7 @@ public interface Topics {
* Remove the deduplication snapshot interval for specified topic.
* @param topic
* @throws PulsarAdminException
+ * @deprecated Use {@link TopicPolicies#removeDeduplicationSnapshotInterval(String)} instead.
*/
@Deprecated
void removeDeduplicationSnapshotInterval(String topic) throws PulsarAdminException;
@@ -3765,6 +3927,7 @@ public interface Topics {
* Remove the deduplication snapshot interval for specified topic asynchronously.
* @param topic
* @return
+ * @deprecated Use {@link TopicPolicies#removeDeduplicationSnapshotIntervalAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeDeduplicationSnapshotIntervalAsync(String topic);
@@ -3777,6 +3940,7 @@ public interface Topics {
* is enable subTypes
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setSubscriptionTypesEnabled(String, Set)} instead.
*/
@Deprecated
void setSubscriptionTypesEnabled(String topic,
@@ -3788,6 +3952,7 @@ public interface Topics {
* @param topic
* @param subscriptionTypesEnabled
* is enable subTypes
+ * @deprecated Use {@link TopicPolicies#setSubscriptionTypesEnabledAsync(String, Set)} instead.
*/
@Deprecated
CompletableFuture<Void> setSubscriptionTypesEnabledAsync(String topic,
@@ -3801,6 +3966,7 @@ public interface Topics {
* @return set of enable sub types {@link Set<SubscriptionType>}
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getSubscriptionTypesEnabled(String)} instead.
*/
@Deprecated
Set<SubscriptionType> getSubscriptionTypesEnabled(String topic) throws PulsarAdminException;
@@ -3810,6 +3976,7 @@ public interface Topics {
*
* @param topic
* is topic for get is enable sub types
+ * @deprecated Use {@link TopicPolicies#getSubscriptionTypesEnabledAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Set<SubscriptionType>> getSubscriptionTypesEnabledAsync(String topic);
@@ -3819,6 +3986,7 @@ public interface Topics {
*
* @param topic Topic name
* @throws PulsarAdminException Unexpected error
+ * @deprecated Use {@link TopicPolicies#removeSubscriptionTypesEnabled(String)} instead.
*/
@Deprecated
void removeSubscriptionTypesEnabled(String topic) throws PulsarAdminException;
@@ -3827,6 +3995,7 @@ public interface Topics {
* Remove subscription types enabled for a topic asynchronously.
*
* @param topic Topic name
+ * @deprecated Use {@link TopicPolicies#removeSubscriptionTypesEnabledAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeSubscriptionTypesEnabledAsync(String topic);
@@ -3839,6 +4008,7 @@ public interface Topics {
* consumer subscribe limit by this subscribeRate
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#setSubscribeRate(String, SubscribeRate)} instead.
*/
@Deprecated
void setSubscribeRate(String topic, SubscribeRate subscribeRate) throws PulsarAdminException;
@@ -3849,6 +4019,7 @@ public interface Topics {
* @param topic
* @param subscribeRate
* consumer subscribe limit by this subscribeRate
+ * @deprecated Use {@link TopicPolicies#setSubscribeRateAsync(String, SubscribeRate)} instead.
*/
@Deprecated
CompletableFuture<Void> setSubscribeRateAsync(String topic, SubscribeRate subscribeRate);
@@ -3860,6 +4031,7 @@ public interface Topics {
* @returns subscribeRate
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getSubscribeRate(String)} instead.
*/
@Deprecated
SubscribeRate getSubscribeRate(String topic) throws PulsarAdminException;
@@ -3871,6 +4043,7 @@ public interface Topics {
*
* @param topic
* @returns subscribeRate
+ * @deprecated Use {@link TopicPolicies#getSubscribeRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<SubscribeRate> getSubscribeRateAsync(String topic);
@@ -3882,6 +4055,7 @@ public interface Topics {
* @returns subscribeRate
* @throws PulsarAdminException
* Unexpected error
+ * @deprecated Use {@link TopicPolicies#getSubscribeRate(String, boolean)} instead.
*/
@Deprecated
SubscribeRate getSubscribeRate(String topic, boolean applied) throws PulsarAdminException;
@@ -3891,6 +4065,7 @@ public interface Topics {
*
* @param topic
* @returns subscribeRate
+ * @deprecated Use {@link TopicPolicies#getSubscribeRateAsync(String, boolean)} instead.
*/
@Deprecated
CompletableFuture<SubscribeRate> getSubscribeRateAsync(String topic, boolean applied);
@@ -3903,6 +4078,7 @@ public interface Topics {
* @param topic
* @throws PulsarAdminException
* unexpected error
+ * @deprecated Use {@link TopicPolicies#removeSubscribeRate(String)} instead.
*/
@Deprecated
void removeSubscribeRate(String topic) throws PulsarAdminException;
@@ -3915,6 +4091,7 @@ public interface Topics {
* @param topic
* @throws PulsarAdminException
* unexpected error
+ * @deprecated Use {@link TopicPolicies#removeSubscribeRateAsync(String)} instead.
*/
@Deprecated
CompletableFuture<Void> removeSubscribeRateAsync(String topic) throws PulsarAdminException;