From 8abd881c791d6b6e69389c2283907de4d0a7be40 Mon Sep 17 00:00:00 2001
From: Oleksiy Afanasenko <oleksiy.afanasenko@exness.com>
Date: Wed, 22 Jan 2025 16:52:12 +0200
Subject: [PATCH] Default timeout for http requests to prevent hanging

---
 .../main/java/io/kafbat/ui/util/WebClientConfigurator.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/api/src/main/java/io/kafbat/ui/util/WebClientConfigurator.java b/api/src/main/java/io/kafbat/ui/util/WebClientConfigurator.java
index 1c289f54f..acc26e508 100644
--- a/api/src/main/java/io/kafbat/ui/util/WebClientConfigurator.java
+++ b/api/src/main/java/io/kafbat/ui/util/WebClientConfigurator.java
@@ -10,6 +10,7 @@
 import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
 import java.io.FileInputStream;
 import java.security.KeyStore;
+import java.time.Duration;
 import java.util.function.Consumer;
 import javax.annotation.Nullable;
 import javax.net.ssl.KeyManagerFactory;
@@ -31,7 +32,8 @@ public class WebClientConfigurator {
   private final WebClient.Builder builder = WebClient.builder();
   private HttpClient httpClient = HttpClient
       .create()
-      .proxyWithSystemProperties();
+      .proxyWithSystemProperties()
+      .responseTimeout(Duration.ofSeconds(10));
 
   public WebClientConfigurator() {
     configureObjectMapper(defaultOM());