diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java index bfef761846ca41271abac0da7da767756fc6d279..ef76cfd4d5195569d64b36cf2e6065e2758fb17a 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java +++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java @@ -94,6 +94,11 @@ public class DefaultLitePullConsumer extends ClientConfig implements LitePullCon */ private int pullThreadNums = 20; + /** + * Minimum commit offset interval time in milliseconds. + */ + private static final long MIN_AUTOCOMMIT_INTERVAL_MILLIS = 1000; + /** * Maximum commit offset interval time in milliseconds. */ @@ -315,7 +320,9 @@ public class DefaultLitePullConsumer extends ClientConfig implements LitePullCon } public void setAutoCommitIntervalMillis(long autoCommitIntervalMillis) { - this.autoCommitIntervalMillis = autoCommitIntervalMillis; + if (autoCommitIntervalMillis >= MIN_AUTOCOMMIT_INTERVAL_MILLIS) { + this.autoCommitIntervalMillis = autoCommitIntervalMillis; + } } public int getPullBatchSize() {