This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a commit to branch 2.8
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.8 by this push:
new 4a17a98 MINOR: socket setup max should be 30 seconds #10306 (#10306)
4a17a98 is described below
commit 4a17a98f2cad21cdacac1050c4dc94995b451d03
Author: Colin Patrick McCabe <[email protected]>
AuthorDate: Thu Mar 11 14:50:43 2021 -0800
MINOR: socket setup max should be 30 seconds #10306 (#10306)
socket.connection.setup.timeout.max.ms should be 30 seconds.
The current value of 127 seconds is longer than the default API timeout
for AdminClient, and longer than the default request timeouts for the
producer and consumer. We should bring these configs into line with
each other.
Reviewers: Jason Gustafson <[email protected]>
---
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
b/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
index 1930cf3..4670f27 100644
--- a/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
+++ b/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
@@ -110,7 +110,7 @@ public class CommonClientConfigs {
public static final String SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG =
"socket.connection.setup.timeout.max.ms";
public static final String SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_DOC =
"The maximum amount of time the client will wait for the socket connection to
be established. The connection setup timeout will increase exponentially for
each consecutive connection failure up to this maximum. To avoid connection
storms, a randomization factor of 0.2 will be applied to the timeout resulting
in a random range between 20% below and 20% above the computed value.";
- public static final Long DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS =
127 * 1000L;
+ public static final Long DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS =
30 * 1000L;
public static final String CONNECTIONS_MAX_IDLE_MS_CONFIG =
"connections.max.idle.ms";
public static final String CONNECTIONS_MAX_IDLE_MS_DOC = "Close idle
connections after the number of milliseconds specified by this config.";