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%)
