Fix Kafka source to override areAcknowlegementsEnabled

Signed-off-by: Krishna Kondaka <[email protected]>
kkondaka · Nov 3, 2024 · e44bfbe · e44bfbe
1 parent e59917d
commit e44bfbe
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...ka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/source/KafkaSource.java b/...ka-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 {