[kafka] 01/01: fix test

[cm...@apache.org]

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 <cm...@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()
   }
 }