From b9da249bdfa9df7a511284d815af8200ab0dfbd9 Mon Sep 17 00:00:00 2001 From: "Colin P. McCabe" Date: Thu, 29 Sep 2022 09:17:03 -0700 Subject: [PATCH] fix test --- .../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() } }