fix: fix 879 (#881)

apache · Nov 29, 2022 · 0b197f7 · 0b197f7
1 parent 4ebb3c7
commit 0b197f7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
@@ -469,7 +469,7 @@ func (pc *partitionConsumer) AckID(msgID MessageID) error {
 		pc.options.interceptors.OnAcknowledge(pc.parentConsumer, msgID)
 	}
 
-	return ackReq.err
+	return nil
 }
 
 func (pc *partitionConsumer) NackID(msgID MessageID) {