Fix nil point exception

apache · Feb 26, 2025 · 29cb448 · 29cb448
1 parent cec93f0
commit 29cb448
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
@@ -622,6 +622,9 @@ func (pc *partitionConsumer) internalUnsubscribe(unsub *unsubscribeRequest) {
 
 func (pc *partitionConsumer) getLastMessageID() (*trackingMessageID, error) {
 	res, err := pc.getLastMessageIDAndMarkDeletePosition()
+	if err != nil {
+		return nil, err
+	}
 	return res.msgID, err
 }