This is an automated email from the ASF dual-hosted git repository.
zike pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new d32b2bc6f03 [improve][broker] Add annotation for topic compaction
strategy (#20858)
d32b2bc6f03 is described below
commit d32b2bc6f031e9a8e0fbf7f8212dc6d56df2deb2
Author: Kai Wang <[email protected]>
AuthorDate: Wed Jul 26 13:16:27 2023 +0800
[improve][broker] Add annotation for topic compaction strategy (#20858)
### Motivation
Add `Audience.Private` annotation for topic compaction strategy. Since this
interface only uses for load manager, other users should not use this interface.
(cherry picked from commit e55ed58eed4380b463d04b76dbb953d7a0ac795d)
---
.../java/org/apache/pulsar/common/topics/TopicCompactionStrategy.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/pulsar-common/src/main/java/org/apache/pulsar/common/topics/TopicCompactionStrategy.java
b/pulsar-common/src/main/java/org/apache/pulsar/common/topics/TopicCompactionStrategy.java
index 51fb6742961..39bfa6d71bc 100644
---
a/pulsar-common/src/main/java/org/apache/pulsar/common/topics/TopicCompactionStrategy.java
+++
b/pulsar-common/src/main/java/org/apache/pulsar/common/topics/TopicCompactionStrategy.java
@@ -21,6 +21,8 @@ package org.apache.pulsar.common.topics;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.apache.pulsar.client.api.Schema;
+import org.apache.pulsar.common.classification.InterfaceAudience;
+import org.apache.pulsar.common.classification.InterfaceStability;
/**
* Defines a custom strategy to compact messages in a topic.
@@ -45,6 +47,8 @@ import org.apache.pulsar.client.api.Schema;
* "topicCompactionStrategyClassName",
strategy.getClass().getCanonicalName()))
* .create();
*/
[email protected]
[email protected]
public interface TopicCompactionStrategy<T> {
String TABLE_VIEW_TAG = "table-view";
