dekaf: Frequently kill idle connections

estuary · Oct 4, 2024 · 4864c05 · 4864c05
1 parent 3919b53
commit 4864c05
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/crates/dekaf/src/api_client.rs b/crates/dekaf/src/api_client.rs
@@ -375,9 +375,9 @@ impl KafkaApiClient {
         // It seems that after running for a while, connections can get into
         // a broken state where every response returns an error. This, plus
         // the healthcheck when recycling a connection solves that problem.
-        let reap_interval = Duration::from_secs(30);
+        let reap_interval = Duration::from_secs(5);
         let max_age = Duration::from_secs(60 * 30);
-        let max_idle = Duration::from_secs(60 * 5);
+        let max_idle = Duration::from_secs(0);
         let reaper = tokio_util::task::AbortOnDropHandle::new(tokio::spawn({
             let pool = pool.clone();
             let broker_url = broker_url.to_string();