changing idle timeout to 60 seconds (#791)

The reason for this is based on what we've observed at multiple user deployments, this value seems to make the system more stable for heavier loads as we keep the START_REPLICATION connection open for longer Co-authored-by: Philip Dubé <[email protected]>
PeerDB-io · Dec 12, 2023 · 925cbe6 · 925cbe6
1 parent c0b9f1e
commit 925cbe6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -234,7 +234,7 @@ func (a *FlowableActivity) StartFlow(ctx context.Context,
 		tblNameMapping[v.SourceTableIdentifier] = model.NewNameAndExclude(v.DestinationTableIdentifier, v.Exclude)
 	}
 
-	idleTimeout := utils.GetEnvInt("PEERDB_CDC_IDLE_TIMEOUT_SECONDS", 10)
+	idleTimeout := utils.GetEnvInt("PEERDB_CDC_IDLE_TIMEOUT_SECONDS", 60)
 
 	recordBatch := model.NewCDCRecordStream()