diff --git a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java index 0a1bfa5d67..d859f965e4 100644 --- a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java +++ b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java @@ -310,7 +310,7 @@ public class BrokerConfig extends BrokerIdentity { private boolean asyncSendEnable = true; - private boolean useServerSideResetOffset = false; + private boolean useServerSideResetOffset = true; private long consumerOffsetUpdateVersionStep = 500;