Merge pull request #7 from Appdynamics/2.0.2

fixing useSsl null ptr
Appdynamics · Jan 23, 2019 · f2968f4 · f2968f4
2 parents f476e0c + a1d6999
commit f2968f4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/com/appdynamics/extensions/kafka/KafkaMonitorTask.java b/src/main/java/com/appdynamics/extensions/kafka/KafkaMonitorTask.java
@@ -100,6 +100,7 @@ private BigDecimal openJMXConnection () {
             Map<String, String> requestMap = buildRequestMap();
             jmxAdapter = JMXConnectionAdapter.create(requestMap);
             Map<String, Object> connectionMap = (Map<String, Object>) getConnectionParameters();
+            connectionMap.put(Constants.USE_SSL, this.kafkaServer.get(Constants.USE_SSL));
             logger.debug("[useSsl] is set [{}] for server [{}]", connectionMap.get(Constants.USE_SSL),
                     this.kafkaServer.get(Constants.DISPLAY_NAME));
             if (configuration.getConfigYml().containsKey(Constants.ENCRYPTION_KEY) &&