From 149e25bce78ac6c68f1f493482b7055c745388da Mon Sep 17 00:00:00 2001
From: SowmyaDixit <sowmyadixit7@gmail.com>
Date: Tue, 23 Mar 2021 10:28:41 +0530
Subject: [PATCH] Issue #TG-717 feat: Secor on Kubernetes: Set auto commit
 offset to false

---
 src/main/java/com/pinterest/secor/common/SecorKafkaClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/pinterest/secor/common/SecorKafkaClient.java b/src/main/java/com/pinterest/secor/common/SecorKafkaClient.java
index 363a61660..0366aa976 100644
--- a/src/main/java/com/pinterest/secor/common/SecorKafkaClient.java
+++ b/src/main/java/com/pinterest/secor/common/SecorKafkaClient.java
@@ -109,7 +109,7 @@ public void init(SecorConfig config) {
         mPollTimeout = config.getNewConsumerPollTimeoutSeconds();
         Properties props = new Properties();
         props.put("bootstrap.servers", config.getKafkaSeedBrokerHost() + ":" + config.getKafkaSeedBrokerPort());
-        props.put("enable.auto.commit", true);
+        props.put("enable.auto.commit", false);
         props.put("auto.offset.reset", "earliest");
         props.put("key.deserializer", ByteArrayDeserializer.class);
         props.put("value.deserializer", ByteArrayDeserializer.class);