cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801158397
##########
File path:
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
##########
@@ -321,7 +340,11 @@ class AuthorizerIntegrationTest extends BaseRequestTest {
// Allow inter-broker communication
addAndVerifyAcls(Set(new AccessControlEntry(brokerPrincipal.toString,
WildcardHost, CLUSTER_ACTION, ALLOW)), clusterResource)
- TestUtils.createOffsetsTopic(zkClient, servers)
+ if (isKRaftTest()) {
+ TestUtils.createOffsetsTopicWithAdmin(brokers)
Review comment:
It doesn't quite work in the ZK case since if the broker isn't a super
user, we don't have the ability to create the topic with the broker principal.
--
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
