diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkDisable.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkDisable.java
index 8d713134f1f216e23ad82fe9f510286881506c38..da15d3bff37afaf921f1e3a54d3ba7161532320a 100644
--- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkDisable.java
+++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkDisable.java
@@ -43,7 +43,7 @@ public class PulsarSinkDisable<T> implements Sink<T> {
 
     @Override
     public void write(Record<T> record) throws Exception {
-        // No-op
+        record.ack();
     }
 
 }