cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r801160275
##########
File path: core/src/test/scala/unit/kafka/utils/TestUtils.scala
##########
@@ -2106,32 +2106,65 @@ object TestUtils extends Logging {
s"There still are ongoing reassignments", pause = pause)
}
- def addAndVerifyAcls(broker: KafkaBroker, acls: Set[AccessControlEntry],
resource: ResourcePattern): Unit = {
- val authorizer = broker.dataPlaneRequestProcessor.authorizer.get
+ /**
+ * Find an Authorizer that we can call createAcls or deleteAcls on.
+ */
+ def pickAuthorizerForWrite[B <: KafkaBroker](
Review comment:
It's possible, but I think it would be a lot of extra work to convert
the test to do that. There are some other tests that do go through the admin
API (citation needed?) so hopefully we can just rely on those
--
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
