Set new default timeout to 3 minutes / 180 seconds based on the metri…

…cs data from `consumer_records_producing_to_write_buffer_latency`. 📬
linkedin · Oct 9, 2024 · 03ba493 · 03ba493
1 parent eb549a5
commit 03ba493
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerService.java b/...-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerService.java
@@ -71,7 +71,7 @@ public abstract class KafkaConsumerService extends AbstractKafkaConsumerService
   /**
    * Waiting for the next poll() after unsubscribing, indicating that all previous inflight messages were processed
    */
-  public static final long DEFAULT_WAIT_AFTER_UNSUBSCRIBE_TIMEOUT_MS = TimeUnit.MINUTES.toMillis(5);
+  public static final long DEFAULT_WAIT_AFTER_UNSUBSCRIBE_TIMEOUT_MS = TimeUnit.MINUTES.toMillis(3);
   /**
    * A shorter timeout wait during shutdown / termination to avoid blocking the shutdown process
    */