fix: fix 879

apache · Nov 2, 2022 · 749b685 · 749b685
1 parent 0b0720a
commit 749b685
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
@@ -447,7 +447,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) {