fix: remove deprecated Acl API (#4373)

confluentinc · Jan 23, 2020 · a2b69f7 · a2b69f7
1 parent 0edfd24
commit a2b69f7
Showing 1 changed file with 2 additions and 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
@@ -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();