From e44bfbe5e36baa32e19dc7842156c550efe7402d Mon Sep 17 00:00:00 2001
From: Krishna Kondaka <krishkdk@amazon.com>
Date: Sun, 3 Nov 2024 22:36:02 +0000
Subject: [PATCH] Fix Kafka source to override areAcknowlegementsEnabled

Signed-off-by: Krishna Kondaka <krishkdk@amazon.com>
---
 .../dataprepper/plugins/kafka/source/KafkaSource.java        | 5 +++++
 1 file changed, 5 insertions(+)

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 {