From 331af5490b63a4e3091f9ae7ac01d58fe8bdd1bc Mon Sep 17 00:00:00 2001 From: Thomas Lee Date: Thu, 8 Aug 2024 17:04:47 +0800 Subject: [PATCH] fix consumePullResult npe --- .../org/apache/rocketmq/exporter/task/MetricsCollectTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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();