fix: fix 879

apache · Nov 2, 2022 · db525c3 · db525c3
1 parent 44b64aa
commit db525c3
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) {