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);