diff --git a/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
index e2e5f00..558bf1e 100644
--- a/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
+++ b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
@@ -393,7 +393,7 @@ public void collectConsumerOffset() {
                                 if (offset.getBrokerOffset() == offset.getConsumerOffset()) {
                                     lagTime = 0;
                                 }
-                            } else if (consumePullResult.getPullStatus() == PullStatus.OFFSET_ILLEGAL) {
+                            } else if (consumePullResult != null && consumePullResult.getPullStatus() == PullStatus.OFFSET_ILLEGAL) {
                                 PullResult pullResult = ((MQAdminExtImpl) mqAdminExt).queryMsgByOffset(q, consumePullResult.getMinOffset());
                                 if (pullResult != null && pullResult.getPullStatus() == PullStatus.FOUND) {
                                     lagTime = System.currentTimeMillis() - pullResult.getMsgFoundList().get(0).getStoreTimestamp();