Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9893

Configurable TCP connection timeout and improve the initial metadata fetch

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Resolved
    • Priority: Major
    • Resolution: Implemented
    • Affects Version/s: 2.7.0
    • Fix Version/s: 2.7.0
    • Component/s: core
    • Labels:
      None

      Description

      This issue has two parts:

      1. Support transportation layer connection timeout described in KIP-601
      2. Optimize the logic for NetworkClient.leastLoadedNode()

      Changes:

      1. Added a new common client configuration parameter socket.connection.setup.timeout.ms to the NetworkClient. Handle potential transportation layer timeout using the same approach as it handling potential request timeout.
      2. When no connected channel exists, leastLoadedNode() will now provide a disconnected node that has the least number of failed attempts. 
      3. ClusterConnectionStates will keep the connecting node ids. Now it also has several new public methods to provide per connection relavant data.

        Attachments

          Activity

            People

            • Assignee:
              d8tltanc Cheng Tan
              Reporter:
              d8tltanc Cheng Tan

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment