kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mimai...@apache.org
Subject [kafka] branch trunk updated (1c56aba -> 131d475)
Date Thu, 04 Feb 2021 11:44:18 GMT
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%)


Mime
View raw message