mirror of https://github.com/apache/kafka.git
Update `AclCommandTest`
This commit is contained in:
parent
78b8467808
commit
bdf3a570fd
|
@ -116,7 +116,7 @@ class AclCommandTest extends ZooKeeperTestHarness with Logging {
|
||||||
|
|
||||||
private def testRemove(resources: Set[Resource], resourceCmd: Array[String], args: Array[String], brokerProps: Properties) {
|
private def testRemove(resources: Set[Resource], resourceCmd: Array[String], args: Array[String], brokerProps: Properties) {
|
||||||
for (resource <- resources) {
|
for (resource <- resources) {
|
||||||
AclCommand.main(args ++ resourceCmd :+ "--remove" :+ "--yes")
|
AclCommand.main(args ++ resourceCmd :+ "--remove" :+ "--force")
|
||||||
withAuthorizer(brokerProps) { authorizer =>
|
withAuthorizer(brokerProps) { authorizer =>
|
||||||
TestUtils.waitAndVerifyAcls(Set.empty[Acl], authorizer, resource)
|
TestUtils.waitAndVerifyAcls(Set.empty[Acl], authorizer, resource)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue