You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by mi...@apache.org on 2021/02/04 11:44:18 UTC

[kafka] branch trunk updated (1c56aba -> 131d475)

This is an automated email from the ASF dual-hosted git repository.

mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 1c56aba  MINOR: Fix always pass unit test in MetadataRequestTest (#10033)
     add 131d475  KAFKA-12193: Re-resolve IPs after a client disconnects (#9902)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/clients/ClientUtils.java |   5 +-
 .../kafka/clients/ClusterConnectionStates.java     |  26 +++-
 .../DefaultHostResolver.java}                      |  15 +-
 .../org/apache/kafka/clients/HostResolver.java     |   9 +-
 .../org/apache/kafka/clients/NetworkClient.java    |  80 +++++-----
 .../kafka/clients/AddressChangeHostResolver.java}  |  34 +++--
 .../org/apache/kafka/clients/ClientUtilsTest.java  |   9 +-
 .../kafka/clients/ClusterConnectionStatesTest.java |  71 ++++++---
 .../apache/kafka/clients/NetworkClientTest.java    | 163 +++++++++++++++++++++
 .../java/org/apache/kafka/test/MockSelector.java   |  11 +-
 10 files changed, 327 insertions(+), 96 deletions(-)
 copy clients/src/main/java/org/apache/kafka/{common/security/authenticator/DefaultLogin.java => clients/DefaultHostResolver.java} (74%)
 copy streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java => clients/src/main/java/org/apache/kafka/clients/HostResolver.java (80%)
 copy clients/src/{main/java/org/apache/kafka/common/security/auth/PlaintextAuthenticationContext.java => test/java/org/apache/kafka/clients/AddressChangeHostResolver.java} (52%)