diff --git a/mq-starter-core/src/main/java/com/njcn/mq/annotation/MqListener.java b/mq-starter-core/src/main/java/com/njcn/mq/annotation/MqListener.java
index 303ff03..52ac0b3 100644
--- a/mq-starter-core/src/main/java/com/njcn/mq/annotation/MqListener.java
+++ b/mq-starter-core/src/main/java/com/njcn/mq/annotation/MqListener.java
@@ -13,8 +13,8 @@ public @interface MqListener {
     int batchSize() default 1;
     int maxRetry() default 3;
     String tag() default "*";
-    /** 是否启用消费去重（按 key）。默认关闭。 */
-    boolean idempotent() default false;
+    /** 是否启用消费去重（按 key）。默认开启，不需要去重时显式置 false。 */
+    boolean idempotent() default true;
     /** 异常落库回调的 bean 名；空表示不落库。 */
     String errorHandler() default "";
 }
diff --git a/mq-starter-core/src/main/java/com/njcn/mq/container/MqListenerRegistry.java b/mq-starter-core/src/main/java/com/njcn/mq/container/MqListenerRegistry.java
index 2e74217..2dcd621 100644
--- a/mq-starter-core/src/main/java/com/njcn/mq/container/MqListenerRegistry.java
+++ b/mq-starter-core/src/main/java/com/njcn/mq/container/MqListenerRegistry.java
@@ -37,7 +37,7 @@ public class MqListenerRegistry implements SmartLifecycle {
         for (MqListenerEndpoint ep : endpoints) {
             MqListener meta = ep.getMeta();
             if (meta.idempotent() && store == null) {
-                log.warn("[mq] @MqListener(idempotent=true) 但容器中无 MqIdempotentStore bean，去重不生效: topic={} group={}",
+                log.warn("[mq] @MqListener 去重已启用（idempotent 默认 true）但容器中无 MqIdempotentStore bean，去重不生效: topic={} group={}",
                         meta.topic(), meta.group());
             }
             MqConsumeErrorHandler eh = resolveErrorHandler(meta);