This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 95581f3 MINOR: Adds entity-specific flags to ConfigCommand per
KIP-543. (#7667)
add 5b6de9f KAFKA-8933; Fix NPE in DefaultMetadataUpdater after
authentication failure (#7682)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/ManualMetadataUpdater.java | 23 ++---
.../java/org/apache/kafka/clients/Metadata.java | 17 +++-
.../org/apache/kafka/clients/MetadataUpdater.java | 29 +++---
.../org/apache/kafka/clients/NetworkClient.java | 112 ++++++++++-----------
.../admin/internals/AdminMetadataManager.java | 17 ++--
.../kafka/clients/consumer/KafkaConsumer.java | 2 +-
.../kafka/clients/producer/KafkaProducer.java | 2 +-
.../producer/internals/ProducerMetadata.java | 7 +-
.../org/apache/kafka/clients/MetadataTest.java | 19 +++-
.../apache/kafka/clients/NetworkClientTest.java | 77 +++++++++++++-
.../internals/ConsumerNetworkClientTest.java | 4 +-
.../clients/consumer/internals/FetcherTest.java | 2 +-
.../producer/internals/ProducerMetadataTest.java | 8 +-
.../ClientAuthenticationFailureTest.java | 40 +++-----
.../java/org/apache/kafka/test/MockSelector.java | 20 ++--
.../runtime/distributed/WorkerGroupMember.java | 2 +-
.../kafka/admin/BrokerApiVersionsCommand.scala | 2 +-
17 files changed, 219 insertions(+), 164 deletions(-)
