This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from a225347 KAFKA-8840: Fix bug where ClientCompatibilityFeaturesTest
fails when running multiple iterations (#7260)
add 3647948 KAFKA-8760; New Java Authorizer API (KIP-504) (#7268)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
checkstyle/import-control.xml | 2 +
.../java/org/apache/kafka/common/Endpoint.java | 101 +++
.../kafka/common/requests/RequestContext.java | 42 +-
.../apache/kafka/common/utils/SecurityUtils.java | 44 ++
.../authorizer/AclCreateResult.java} | 36 +-
.../kafka/server/authorizer/AclDeleteResult.java | 97 +++
.../org/apache/kafka/server/authorizer/Action.java | 124 +++
.../authorizer/AuthorizableRequestContext.java | 72 ++
.../server/authorizer/AuthorizationResult.java | 10 +-
.../apache/kafka/server/authorizer/Authorizer.java | 110 +++
.../authorizer/AuthorizerServerInfo.java} | 41 +-
core/src/main/scala/kafka/admin/AclCommand.scala | 220 ++++--
.../src/main/scala/kafka/admin/ConfigCommand.scala | 2 +-
core/src/main/scala/kafka/cluster/Broker.scala | 28 +-
core/src/main/scala/kafka/cluster/EndPoint.scala | 9 +-
.../transaction/TransactionStateManager.scala | 2 +-
.../main/scala/kafka/network/SocketServer.scala | 31 +-
.../scala/kafka/security/auth/Authorizer.scala | 1 +
.../kafka/security/auth/SimpleAclAuthorizer.scala | 382 ++-------
.../AclAuthorizer.scala} | 282 ++++---
.../AuthorizerUtils.scala} | 56 +-
.../security/authorizer/AuthorizerWrapper.scala | 136 ++++
.../scala/kafka/server/DynamicBrokerConfig.scala | 4 +
core/src/main/scala/kafka/server/KafkaApis.scala | 401 +++++-----
core/src/main/scala/kafka/server/KafkaConfig.scala | 20 +-
core/src/main/scala/kafka/server/KafkaServer.scala | 21 +-
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 2 +-
core/src/main/scala/kafka/zk/ZkData.scala | 2 +-
.../kafka/api/AdminClientIntegrationTest.scala | 4 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 384 ++++-----
.../DelegationTokenEndToEndAuthorizationTest.scala | 2 +-
.../api/DescribeAuthorizedOperationsTest.scala | 30 +-
.../kafka/api/EndToEndAuthorizationTest.scala | 73 +-
.../SaslClientsWithInvalidCredentialsTest.scala | 2 +-
.../SaslGssapiSslEndToEndAuthorizationTest.scala | 2 +
.../api/SaslSslAdminClientIntegrationTest.scala | 21 +-
.../kafka/api/SslAdminClientIntegrationTest.scala | 90 +++
.../scala/unit/kafka/admin/AclCommandTest.scala | 107 +--
.../kafka/admin/LeaderElectionCommandTest.scala | 2 +-
...PreferredReplicaLeaderElectionCommandTest.scala | 22 +-
.../unit/kafka/network/SocketServerTest.scala | 51 +-
.../security/auth/SimpleAclAuthorizerTest.scala | 40 +-
.../security/authorizer/AclAuthorizerTest.scala | 877 +++++++++++++++++++++
.../delegation/DelegationTokenManagerTest.scala | 59 +-
.../kafka/server/DynamicBrokerConfigTest.scala | 44 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 2 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 14 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 15 +-
49 files changed, 3023 insertions(+), 1097 deletions(-)
create mode 100644 clients/src/main/java/org/apache/kafka/common/Endpoint.java
copy
clients/src/main/java/org/apache/kafka/{clients/admin/ExpireDelegationTokenResult.java
=> server/authorizer/AclCreateResult.java} (57%)
create mode 100644
clients/src/main/java/org/apache/kafka/server/authorizer/AclDeleteResult.java
create mode 100644
clients/src/main/java/org/apache/kafka/server/authorizer/Action.java
create mode 100644
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java
copy
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetterSupplier.java
=>
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizationResult.java
(80%)
create mode 100644
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java
copy
clients/src/main/java/org/apache/kafka/{clients/admin/CreateTopicsResult.java
=> server/authorizer/AuthorizerServerInfo.java} (53%)
copy core/src/main/scala/kafka/security/{auth/SimpleAclAuthorizer.scala =>
authorizer/AclAuthorizer.scala} (58%)
rename core/src/main/scala/kafka/security/{SecurityUtils.scala =>
authorizer/AuthorizerUtils.scala} (52%)
create mode 100644
core/src/main/scala/kafka/security/authorizer/AuthorizerWrapper.scala
create mode 100644
core/src/test/scala/integration/kafka/api/SslAdminClientIntegrationTest.scala
create mode 100644
core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerTest.scala
