diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java index 3b39b86cc71..50827545b69 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java @@ -26,7 +26,7 @@ public class PopProcessQueue { private final static long PULL_MAX_IDLE_TIME = Long.parseLong(System.getProperty("rocketmq.client.pull.pullMaxIdleTime", "120000")); - private long lastPopTimestamp; + private long lastPopTimestamp = System.currentTimeMillis(); private AtomicInteger waitAckCounter = new AtomicInteger(0); private volatile boolean dropped = false;