[kafka] branch trunk updated (5df8457 -> 0814e4f)

[bo...@apache.org]

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

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


    from 5df8457  KAFKA-7987: Reinitialize ZookeeperClient after auth failures (#7751)
     add 0814e4f  KAFKA-10181: Use Envelope RPC to do redirection for (Incremental)AlterConfig, AlterClientQuota and CreateTopics (#9103)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |   4 +
 .../org/apache/kafka/clients/ClientRequest.java    |  10 +-
 .../kafka/clients/RequestCompletionHandler.java    |   2 +-
 .../kafka/clients/admin/KafkaAdminClient.java      |  36 +-
 .../consumer/internals/ConsumerNetworkClient.java  |   2 +-
 .../kafka/clients/producer/internals/Sender.java   |   4 +-
 .../apache/kafka/common/config/AbstractConfig.java |  11 +
 ...java => PrincipalDeserializationException.java} |   6 +-
 .../apache/kafka/common/network/Authenticator.java |   6 +
 .../apache/kafka/common/network/KafkaChannel.java  |   5 +
 .../common/network/PlaintextChannelBuilder.java    |   7 +
 .../kafka/common/network/SslChannelBuilder.java    |   7 +
 .../org/apache/kafka/common/protocol/ApiKeys.java  |  38 +-
 .../org/apache/kafka/common/protocol/Errors.java   |   5 +-
 .../kafka/common/requests/AbstractRequest.java     |   2 +
 .../kafka/common/requests/AbstractResponse.java    |  24 +-
 .../kafka/common/requests/AlterConfigsRequest.java |   7 +-
 .../common/requests/AlterConfigsResponse.java      |   4 +
 .../kafka/common/requests/ApiVersionsResponse.java |  61 +-
 .../kafka/common/requests/EnvelopeRequest.java     |  94 +++
 ...MetadataResponse.java => EnvelopeResponse.java} |  34 +-
 .../requests/IncrementalAlterConfigsRequest.java   |  30 +
 .../requests/IncrementalAlterConfigsResponse.java  |  29 +-
 .../kafka/common/requests/RequestContext.java      |  31 +-
 .../kafka/common/requests/RequestHeader.java       |  15 +-
 .../kafka/common/security/auth/KafkaPrincipal.java |   5 +
 ...cationContext.java => KafkaPrincipalSerde.java} |  29 +-
 .../DefaultKafkaPrincipalBuilder.java              |  36 +-
 .../authenticator/SaslClientAuthenticator.java     |   6 +
 .../authenticator/SaslServerAuthenticator.java     |  11 +-
 ...hangeMessage.json => DefaultPrincipalData.json} |  19 +-
 ...ribeQuorumRequest.json => EnvelopeRequest.json} |  22 +-
 ...edentialsRequest.json => EnvelopeResponse.json} |  17 +-
 .../org/apache/kafka/clients/ApiVersionsTest.java  |   1 -
 .../apache/kafka/clients/NetworkClientTest.java    |  34 +-
 .../clients/consumer/internals/FetcherTest.java    |   7 +-
 .../clients/producer/internals/SenderTest.java     |   7 +-
 .../kafka/common/protocol/ProtoUtilsTest.java      |  11 +-
 .../common/requests/AbstractResponseTest.java      |  53 ++
 .../common/requests/ApiVersionsResponseTest.java   |  65 --
 .../kafka/common/requests/EnvelopeRequestTest.java |  40 +
 .../kafka/common/requests/RequestContextTest.java  |   3 +-
 .../auth/DefaultKafkaPrincipalBuilderTest.java     |  27 +
 core/src/main/scala/kafka/api/ApiVersion.scala     |  47 +-
 .../main/scala/kafka/network/RequestChannel.scala  |  66 +-
 .../main/scala/kafka/network/SocketServer.scala    | 173 ++++-
 .../kafka/security/authorizer/AclAuthorizer.scala  |   7 +-
 .../src/main/scala/kafka/server/AdminManager.scala |   2 +-
 .../BrokerToControllerChannelManagerImpl.scala     |  55 +-
 .../scala/kafka/server/ClientQuotaManager.scala    |   2 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   | 141 +++-
 core/src/main/scala/kafka/server/KafkaConfig.scala |  10 +
 core/src/main/scala/kafka/server/KafkaServer.scala |  36 +-
 core/src/main/scala/kafka/utils/CoreUtils.scala    |   2 +-
 .../kafka/admin/BrokerApiVersionsCommandTest.scala |  10 +-
 .../kafka/api/PlaintextAdminIntegrationTest.scala  |   4 +-
 .../server/DynamicBrokerReconfigurationTest.scala  |   4 +
 ...PreferredReplicaLeaderElectionCommandTest.scala |   5 +-
 .../test/scala/unit/kafka/api/ApiVersionTest.scala | 112 ++-
 .../unit/kafka/network/RequestChannelTest.scala    |  11 +-
 .../unit/kafka/network/SocketServerTest.scala      | 137 +++-
 .../security/authorizer/AclAuthorizerTest.scala    |   2 +-
 .../server/AbstractApiVersionsRequestTest.scala    |   4 +-
 .../kafka/server/BaseClientQuotaManagerTest.scala  |   2 +-
 .../CreateTopicsRequestWithForwardingTest.scala}   |  30 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    | 865 ++++++++++++++++++---
 .../scala/unit/kafka/server/RequestQuotaTest.scala |  25 +-
 .../server/ThrottledChannelExpirationTest.scala    |   2 +-
 .../kafka/jmh/acl/AclAuthorizerBenchmark.java      |   2 +-
 .../jmh/metadata/MetadataRequestBenchmark.java     |   8 +-
 70 files changed, 2059 insertions(+), 572 deletions(-)
 copy clients/src/main/java/org/apache/kafka/common/errors/{UnstableOffsetCommitException.java => PrincipalDeserializationException.java} (80%)
 create mode 100644 clients/src/main/java/org/apache/kafka/common/requests/EnvelopeRequest.java
 copy clients/src/main/java/org/apache/kafka/common/requests/{UpdateMetadataResponse.java => EnvelopeResponse.java} (68%)
 copy clients/src/main/java/org/apache/kafka/common/security/auth/{AuthenticationContext.java => KafkaPrincipalSerde.java} (51%)
 copy clients/src/main/resources/common/message/{LeaderChangeMessage.json => DefaultPrincipalData.json} (62%)
 copy clients/src/main/resources/common/message/{DescribeQuorumRequest.json => EnvelopeRequest.json} (61%)
 copy clients/src/main/resources/common/message/{DescribeUserScramCredentialsRequest.json => EnvelopeResponse.json} (67%)
 create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/AbstractResponseTest.java
 create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/EnvelopeRequestTest.java
 copy core/src/test/scala/unit/kafka/{utils/PoolTest.scala => server/CreateTopicsRequestWithForwardingTest.scala} (54%)