From 03ba493cbaedd17dda8ab7d8f341b7b8efc1d2b5 Mon Sep 17 00:00:00 2001 From: Kai-Sern Lim Date: Tue, 8 Oct 2024 18:22:44 -0700 Subject: [PATCH] =?UTF-8?q?Set=20new=20default=20timeout=20to=203=20minute?= =?UTF-8?q?s=20/=20180=20seconds=20based=20on=20the=20metrics=20data=20fro?= =?UTF-8?q?m=20`consumer=5Frecords=5Fproducing=5Fto=5Fwrite=5Fbuffer=5Flat?= =?UTF-8?q?ency`.=20=F0=9F=93=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../linkedin/davinci/kafka/consumer/KafkaConsumerService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerService.java b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerService.java index ad70ea8483..f50b5da836 100644 --- a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerService.java +++ b/clients/da-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 */