added truststore&keystorePasword

Author: wkd-woo

src/main/java/kafdrop/config/KafkaConfiguration.java

@@ -25,8 +25,10 @@ public final class KafkaConfiguration {
   private String saslMechanism;
   private String securityProtocol;
   private String truststoreFile;
+  private String truststorePassword;
   private String propertiesFile;
   private String keystoreFile;
+  private String keystorePassword;
 
   public void applyCommon(Properties properties) {
     properties.setProperty(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, brokerConnect);
@@ -39,12 +41,18 @@ public void applyCommon(Properties properties) {
     if (new File(truststoreFile).isFile()) {
       LOG.info("Assigning truststore location to {}", truststoreFile);
       properties.put("ssl.truststore.location", truststoreFile);
+      if (truststorePassword != null && !truststorePassword.isEmpty()) {
+        properties.put("ssl.truststore.password", truststorePassword);
+      }
     }
 
     LOG.info("Checking keystore file {}", keystoreFile);
     if (new File(keystoreFile).isFile()) {
       LOG.info("Assigning keystore location to {}", keystoreFile);
       properties.put("ssl.keystore.location", keystoreFile);
+      if (keystorePassword != null && !keystorePassword.isEmpty()) {
+        properties.put("ssl.keystore.password", keystorePassword);
+      }
     }
 
     LOG.info("Checking properties file {}", propertiesFile);

src/main/resources/application.yml

@@ -41,5 +41,7 @@ kafka:
   saslMechanism: "PLAIN"
   securityProtocol: "SASL_PLAINTEXT"
   truststoreFile: "${KAFKA_TRUSTSTORE_FILE:kafka.truststore.jks}"
-  propertiesFile : "${KAFKA_PROPERTIES_FILE:kafka.properties}"
   keystoreFile: "${KAFKA_KEYSTORE_FILE:kafka.keystore.jks}"
+  propertiesFile: "${KAFKA_PROPERTIES_FILE:kafka.properties}"
+  truststorePassword: "${KAFKA_TRUSTSTORE_PASSWORD}"
+  keystorePassword: "${KAFKA_KEYSTORE_PASSWORD}"