Enable acknowledgements for KafkaBuffer plugin (#3584)

Signed-off-by: Hardeep <mzhrde@amazon.com>
opensearch-project · Nov 6, 2023 · 2d7e4d3 · 2d7e4d3
1 parent 60f84ad
commit 2d7e4d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...gins/src/main/java/org/opensearch/dataprepper/plugins/kafka/buffer/KafkaBufferConfig.java b/...gins/src/main/java/org/opensearch/dataprepper/plugins/kafka/buffer/KafkaBufferConfig.java
@@ -125,7 +125,7 @@ public String getClientDnsLookup() {
 
     @Override
     public boolean getAcknowledgementsEnabled() {
-        return false;
+        return true;
     }
 
     public Duration getDrainTimeout() {