This is an automated email from the ASF dual-hosted git repository.
fcsaky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
The following commit(s) were added to refs/heads/main by this push:
new eb67b4c [FLINK-35468][docs] Simplify `isEnableAutoAcknowledgeMessage`
config comment
eb67b4c is described below
commit eb67b4c1855f2634417d833b494c65f46a3f35e6
Author: zhou zhuohan <[email protected]>
AuthorDate: Tue Oct 21 23:52:39 2025 +0800
[FLINK-35468][docs] Simplify `isEnableAutoAcknowledgeMessage` config comment
---
.../connector/pulsar/source/config/SourceConfiguration.java | 13 +++++--------
1 file changed, 5 insertions(+), 8 deletions(-)
diff --git
a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java
b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java
index 765db30..f6999c4 100644
---
a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java
+++
b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java
@@ -112,15 +112,12 @@ public class SourceConfiguration extends
PulsarConfiguration {
}
/**
- * This is used for all subscription type. But the behavior may not be the
same among them. If
- * you don't enable the flink checkpoint, make sure this option is set to
true.
+ * This is used for all subscription type.
+ * If you don't enable the flink checkpoint, please make sure this option
is set to true.
+ * <p>
+ * {@link SubscriptionType#Failover} and {@link
SubscriptionType#Exclusive} would perform
+ * an incremental acknowledgment in a fixed {@link
#getAutoCommitCursorInterval}.
*
- * <ul>
- * <li>{@link SubscriptionType#Shared} and {@link
SubscriptionType#Key_Shared} would
- * immediately acknowledge the message after consuming it.
- * <li>{@link SubscriptionType#Failover} and {@link
SubscriptionType#Exclusive} would perform
- * a incremental acknowledge in a fixed {@link
#getAutoCommitCursorInterval}.
- * </ul>
*/
public boolean isEnableAutoAcknowledgeMessage() {
return enableAutoAcknowledgeMessage;