diff --git a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java
index e235594ce2..cb74b11138 100644
--- a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java
+++ b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java
@@ -113,6 +113,11 @@ public KafkaSource(final KafkaSourceConfig sourceConfig,
         this.updateConfig(kafkaClusterConfigSupplier);
     }
 
+    @Override
+    public boolean areAcknowledgementsEnabled() {
+        return sourceConfig.getAcknowledgementsEnabled();
+    }
+
     @Override
     public void start(Buffer<Record<Event>> buffer) {
         try {