Updating application props

muralibasani · Sep 25, 2019 · 9d47afc · 9d47afc
1 parent 1cf627e
commit 9d47afc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/com/kafkamgt/clusterapi/utils/GetAdminClient.java b/src/main/java/com/kafkamgt/clusterapi/utils/GetAdminClient.java
@@ -19,7 +19,7 @@ public class GetAdminClient {
     public AdminClient getAdminClient(String envHost){
 
         String envOnlyHost = envHost.substring(0,envHost.indexOf(":"));
-        String ssl_acl_enabled = env.getProperty(envOnlyHost+".ssl_acl.enabled");
+        String ssl_acl_enabled = env.getProperty(envOnlyHost+".connect_with_ssl_kafkacluster");
         if(ssl_acl_enabled==null)
             return AdminClient.create(getPlainProperties(envHost));
         else if(ssl_acl_enabled!=null && ssl_acl_enabled.equals("true"))

diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
@@ -1,7 +1,7 @@
 server.port:9343
 
 # kafka cluster env for DEV/localhost , add more for other envs
-localhost.ssl_acl.enabled=false
+localhost.connect_with_ssl_kafkacluster=false
 
 # SSL properties for DEV/localhost
 kafkassl.localhost.port=9093