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;

Reply via email to