[GitHub] [kafka] dajac commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

dajac commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r445654781 ## File path: clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java ## @@ -357,6 +402,46 @@ private NodeConnectionState nodeState(Strin

[GitHub] [kafka] dajac commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

dajac commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r444951226 ## File path: clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java ## @@ -357,6 +398,36 @@ private NodeConnectionState nodeState(Strin

[GitHub] [kafka] dajac commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

dajac commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r442725547 ## File path: clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java ## @@ -357,6 +399,38 @@ private NodeConnectionState nodeState(Strin

[GitHub] [kafka] dajac commented on a change in pull request #8683: KAFKA-9893: Configurable TCP connection timeout and improve the initial metadata fetch

dajac commented on a change in pull request #8683: URL: https://github.com/apache/kafka/pull/8683#discussion_r440658796 ## File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java ## @@ -678,7 +696,11 @@ public Node leastLoadedNode(long now) { }