Skip to content

Commit 8abd881

Browse files
committed
Default timeout for http requests to prevent hanging
1 parent a5d34a7 commit 8abd881

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

api/src/main/java/io/kafbat/ui/util/WebClientConfigurator.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
1111
import java.io.FileInputStream;
1212
import java.security.KeyStore;
13+
import java.time.Duration;
1314
import java.util.function.Consumer;
1415
import javax.annotation.Nullable;
1516
import javax.net.ssl.KeyManagerFactory;
@@ -31,7 +32,8 @@ public class WebClientConfigurator {
3132
private final WebClient.Builder builder = WebClient.builder();
3233
private HttpClient httpClient = HttpClient
3334
.create()
34-
.proxyWithSystemProperties();
35+
.proxyWithSystemProperties()
36+
.responseTimeout(Duration.ofSeconds(10));
3537

3638
public WebClientConfigurator() {
3739
configureObjectMapper(defaultOM());

0 commit comments

Comments
 (0)