cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801155285
##########
File path:
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
##########
@@ -147,7 +150,12 @@ class AuthorizerIntegrationTest extends BaseRequestTest {
consumerConfig.setProperty(ConsumerConfig.GROUP_ID_CONFIG, group)
override def brokerPropertyOverrides(properties: Properties): Unit = {
- properties.put(KafkaConfig.AuthorizerClassNameProp,
classOf[AclAuthorizer].getName)
+ if (isKRaftTest()) {
+ properties.put(KafkaConfig.AuthorizerClassNameProp,
classOf[StandardAuthorizer].getName)
+ properties.put(StandardAuthorizer.SUPER_USERS_CONFIG,
BrokerPrincipal.toString())
+ } else {
+ properties.put(KafkaConfig.AuthorizerClassNameProp,
classOf[AclAuthorizer].getName)
Review comment:
There is a chicken / egg problem with the broker connecting to the
controller quorum in the absence of ACLs. Basically the bootstrapping problem.
It doesn't really change the test logic since the test in ZK mode just gives
the broker all the permissions it needs in the setUp function, then moves on
(it doesn't test cases where the broker lacks permissions)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
