From a2b69f7d15022e65a356f8261b278f01e5239df0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sergio=20Pe=C3=B1a?= <sergio@confluent.io>
Date: Thu, 23 Jan 2020 12:15:06 -0600
Subject: [PATCH] fix: remove deprecated Acl API (#4373)

---
 .../io/confluent/ksql/integration/SecureIntegrationTest.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/ksql-engine/src/test/java/io/confluent/ksql/integration/SecureIntegrationTest.java b/ksql-engine/src/test/java/io/confluent/ksql/integration/SecureIntegrationTest.java
index 89504cc3888e..e45b5887995f 100644
--- a/ksql-engine/src/test/java/io/confluent/ksql/integration/SecureIntegrationTest.java
+++ b/ksql-engine/src/test/java/io/confluent/ksql/integration/SecureIntegrationTest.java
@@ -66,7 +66,6 @@
 import java.util.concurrent.atomic.AtomicInteger;
 import javax.net.ssl.HostnameVerifier;
 import javax.net.ssl.HttpsURLConnection;
-import kafka.security.auth.Acl;
 import kafka.zookeeper.ZooKeeperClientException;
 import org.apache.kafka.clients.admin.Admin;
 import org.apache.kafka.clients.admin.AdminClient;
@@ -161,11 +160,11 @@ public void shouldRunQueryAgainstKafkaClusterOverSsl() throws Exception {
                   ops(DESCRIBE_CONFIGS, CREATE));
 
     givenAllowAcl(ALL_USERS,
-                  resource(TOPIC, Acl.WildCardResource()),
+                  resource(TOPIC, ResourcePattern.WILDCARD_RESOURCE),
                   ops(DESCRIBE, READ, WRITE, DELETE));
 
     givenAllowAcl(ALL_USERS,
-                  resource(GROUP, Acl.WildCardResource()),
+                  resource(GROUP, ResourcePattern.WILDCARD_RESOURCE),
                   ops(DESCRIBE, READ));
 
     final Map<String, Object> configs = getBaseKsqlConfig();