This is an automated email from the ASF dual-hosted git repository. cmccabe pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
commit b9da249bdfa9df7a511284d815af8200ab0dfbd9 Author: Colin P. McCabe <cmcc...@apache.org> AuthorDate: Thu Sep 29 09:17:03 2022 -0700 fix test --- .../test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala b/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala index d6f736055b2..ff1b2f5934d 100644 --- a/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala +++ b/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala @@ -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() } }