This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7beec14 KAFKA-12789: Remove Stale comments for meta response handling
logic (#10700)
add 5b0c58e MINOR: Support using the ZK authorizer with KRaft (#10550)
No new revisions were added by this update.
Summary of changes:
.../common/message/CreateAclsRequest.json | 2 +-
.../common/message/DeleteAclsRequest.json | 2 +-
.../common/message/DescribeAclsRequest.json | 2 +-
.../kafka/security/authorizer/AclAuthorizer.scala | 4 +-
core/src/main/scala/kafka/server/AclApis.scala | 155 +++++++++++++++++++++
.../main/scala/kafka/server/ControllerApis.scala | 4 +
core/src/main/scala/kafka/server/KafkaApis.scala | 107 +-------------
core/src/main/scala/kafka/server/KafkaServer.scala | 24 +---
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 18 ++-
.../scala/unit/kafka/server/KafkaApisTest.scala | 3 +-
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 28 +++-
.../unit/kafka/zookeeper/ZooKeeperClientTest.scala | 2 +-
.../jmh/metadata/MetadataRequestBenchmark.java | 3 +-
tests/kafkatest/sanity_checks/test_bounce.py | 8 +-
.../sanity_checks/test_console_consumer.py | 8 +-
.../sanity_checks/test_verifiable_producer.py | 18 +--
tests/kafkatest/services/kafka/kafka.py | 139 ++++++++++--------
tests/kafkatest/services/kafka/quorum.py | 52 +++----
.../services/kafka/templates/kafka.properties | 6 +-
tests/kafkatest/services/security/kafka_acls.py | 32 ++++-
.../kafkatest/services/security/security_config.py | 40 +++---
.../core/compatibility_test_new_broker_test.py | 2 +-
tests/kafkatest/tests/core/replication_test.py | 6 +-
.../kafkatest/tests/core/round_trip_fault_test.py | 4 +-
tests/kafkatest/tests/core/security_test.py | 16 +--
.../tests/core/zookeeper_authorizer_test.py | 101 ++++++++++++++
26 files changed, 514 insertions(+), 272 deletions(-)
create mode 100644 core/src/main/scala/kafka/server/AclApis.scala
create mode 100644 tests/kafkatest/tests/core/zookeeper_authorizer_test.py
