@@ -859,7 +859,7 @@ void testKafkaClusterWithTlsFunctionality() throws Exception {
859859 Map <String , Object > adminConfig = new HashMap <>(sslProps );
860860 adminConfig .put (AdminClientConfig .REQUEST_TIMEOUT_MS_CONFIG , 30000 );
861861
862- try (AdminClient adminClient = AdminClient .create (adminConfig )) {
862+ try (Admin adminClient = Admin .create (adminConfig )) {
863863 Collection <Node > brokers = adminClient .describeCluster ().nodes ().get (30 , TimeUnit .SECONDS );
864864 assertThat (brokers , is (notNullValue ()));
865865 assertThat (brokers .size (), is (NUMBER_OF_REPLICAS ));
@@ -882,7 +882,7 @@ void testKafkaClusterWithTlsFunctionality() throws Exception {
882882 new StringDeserializer (), new StringDeserializer ())) {
883883
884884 Map <String , Object > adminConfig2 = new HashMap <>(sslProps );
885- try (AdminClient adminClient = AdminClient .create (adminConfig2 )) {
885+ try (Admin adminClient = Admin .create (adminConfig2 )) {
886886 adminClient .createTopics (List .of (new NewTopic (topicName , 1 , (short ) 3 )))
887887 .all ().get (30 , TimeUnit .SECONDS );
888888 }
@@ -947,7 +947,7 @@ void testKafkaClusterWithTlsAndDedicatedRoles() throws Exception {
947947 adminConfig .put ("ssl.keystore.type" , "PKCS12" );
948948 adminConfig .put (AdminClientConfig .REQUEST_TIMEOUT_MS_CONFIG , 30000 );
949949
950- try (AdminClient adminClient = AdminClient .create (adminConfig )) {
950+ try (Admin adminClient = Admin .create (adminConfig )) {
951951 Collection <Node > brokers = adminClient .describeCluster ().nodes ().get (30 , TimeUnit .SECONDS );
952952 assertThat (brokers , is (notNullValue ()));
953953 assertThat (brokers .size (), is (2 ));
0 commit comments