From 1fd52db7b2905e1671399cd3e0010fd5e46b266c Mon Sep 17 00:00:00 2001 From: Jonathan Brunn Date: Thu, 13 May 2021 16:44:31 -0600 Subject: [PATCH] Add option for env variable for kafka_saslJaasConfig --- src/main/java/kafdrop/config/KafkaConfiguration.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/java/kafdrop/config/KafkaConfiguration.java b/src/main/java/kafdrop/config/KafkaConfiguration.java index e866cf81..4bd18ae3 100644 --- a/src/main/java/kafdrop/config/KafkaConfiguration.java +++ b/src/main/java/kafdrop/config/KafkaConfiguration.java @@ -17,6 +17,7 @@ public final class KafkaConfiguration { private static final Logger LOG = LoggerFactory.getLogger(KafkaConfiguration.class); private String brokerConnect; + private String saslJaasConfig; private Boolean isSecured = false; private String saslMechanism; private String securityProtocol; @@ -26,6 +27,7 @@ public final class KafkaConfiguration { public void applyCommon(Properties properties) { properties.setProperty(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, brokerConnect); + properties.setProperty(SaslConfigs.SASL_JAAS_CONFIG, saslJaasConfig); if (isSecured) { LOG.warn("The 'isSecured' property is deprecated; consult README.md on the preferred way to configure security"); properties.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, securityProtocol);