root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

fix test

This commit is contained in:
Colin P. McCabe 2022-09-29 09:17:03 -07:00
parent fc786c335c
commit b9da249bdf
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
View File

@ -2628,8 +2628,7 @@ class AuthorizerIntegrationTest extends BaseRequestTest {
new ResourcePattern(TOPIC, "fooa", PREFIXED))
addAndVerifyAcls(Set(new AccessControlEntry("User:otherPrincipal", WildcardHost, CREATE, ALLOW)),
new ResourcePattern(TOPIC, "foob", PREFIXED))
val future = createAdminClient().createTopics(Collections.
singletonList(new NewTopic("foobar", 1, 1.toShort))).all()
JTestUtils.assertFutureThrows(future, classOf[TopicAuthorizationException])
createAdminClient().createTopics(Collections.
singletonList(new NewTopic("foobar", 1, 1.toShort))).all().get()
}
}