diff --git a/consumer/checkpoint.go b/consumer/checkpoint.go
index e343eae3..ec2a8003 100644
--- a/consumer/checkpoint.go
+++ b/consumer/checkpoint.go
@@ -165,9 +165,7 @@ func (c *Consumer) isVbIdle(vbno uint16, checkpointTime *time.Time) bool {
 	currentTime := time.Now()
 	if checkpointTime.IsZero() == false &&
 		currentTime.Sub(*checkpointTime) < c.idleCheckpointInterval &&
-		c.backupVbStats.getVbStat(vbno, "last_processed_seq_no").(uint64) == c.vbProcessingStats.getVbStat(vbno, "last_processed_seq_no").(uint64) &&
-		c.backupVbStats.getVbStat(vbno, "last_doc_timer_feedback_seqno").(uint64) == c.vbProcessingStats.getVbStat(vbno, "last_doc_timer_feedback_seqno").(uint64) &&
-		c.backupVbStats.getVbStat(vbno, "sent_to_worker_counter").(uint64) == c.vbProcessingStats.getVbStat(vbno, "sent_to_worker_counter").(uint64) {
+		c.backupVbStats.getVbStat(vbno, "last_processed_seq_no").(uint64) == c.vbProcessingStats.getVbStat(vbno, "last_processed_seq_no").(uint64) {
 		return true
 	}
 	*checkpointTime = currentTime
diff --git a/producer/depcfg_parser.go b/producer/depcfg_parser.go
index ab425106..d27395ae 100644
--- a/producer/depcfg_parser.go
+++ b/producer/depcfg_parser.go
@@ -205,7 +205,7 @@ func (p *Producer) parseDepcfg() error {
 	if val, ok := settings["idle_checkpoint_interval"]; ok {
 		p.handlerConfig.IdleCheckpointInterval = int(val.(float64))
 	} else {
-		p.handlerConfig.IdleCheckpointInterval = 30000
+		p.handlerConfig.IdleCheckpointInterval = 1800000
 	}
 
 	if val, ok := settings["log_level"]; ok {