diff --git a/cmd/pulsar-consumer/consumer.go b/cmd/pulsar-consumer/consumer.go
index 8641d6b663..8c75a8843b 100644
--- a/cmd/pulsar-consumer/consumer.go
+++ b/cmd/pulsar-consumer/consumer.go
@@ -114,7 +114,7 @@ func (c *consumer) readMessage(ctx context.Context) error {
 			if !needCommit {
 				continue
 			}
-			err := c.pulsarConsumer.AckID(consumerMsg.ID())
+			err := c.pulsarConsumer.AckIDCumulative(consumerMsg.ID())
 			if err != nil {
 				log.Panic("Error ack message", zap.Error(err))
 			}