fixes #197 Use NoneDecryptedInstance to load the config for registerM…

…odule (#198)
networknt · Feb 2, 2024 · b1e4071 · b1e4071
1 parent b4f8ae8
commit b1e4071
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/kafka-consumer/src/main/java/com/networknt/kafka/consumer/KafkaConsumerManager.java b/kafka-consumer/src/main/java/com/networknt/kafka/consumer/KafkaConsumerManager.java
@@ -99,7 +99,7 @@ public KafkaConsumerManager(final KafkaConsumerConfig config) {
     masks.add("basic.auth.user.info");
     masks.add("sasl.jaas.config");
     masks.add("schema.registry.ssl.truststore.password");
-    ModuleRegistry.registerModule(KafkaConsumerConfig.CONFIG_NAME, KafkaConsumerManager.class.getName(), Config.getInstance().getJsonMapConfigNoCache(KafkaConsumerConfig.CONFIG_NAME), masks);
+    ModuleRegistry.registerModule(KafkaConsumerConfig.CONFIG_NAME, KafkaConsumerManager.class.getName(), Config.getNoneDecryptedInstance().getJsonMapConfigNoCache(KafkaConsumerConfig.CONFIG_NAME), masks);
 
     // Cached thread pool
     int maxThreadCount = config.getMaxConsumerThreads();

diff --git a/kafka-consumer/src/main/java/com/networknt/kafka/consumer/LightConsumer.java b/kafka-consumer/src/main/java/com/networknt/kafka/consumer/LightConsumer.java
@@ -21,6 +21,6 @@ default void registerModule() {
         masks.add("basic.auth.user.info");
         masks.add("sasl.jaas.config");
         masks.add("schema.registry.ssl.truststore.password");
-        ModuleRegistry.registerModule(KafkaConsumerConfig.CONFIG_NAME, LightConsumer.class.getName(), Config.getInstance().getJsonMapConfigNoCache(KafkaConsumerConfig.CONFIG_NAME), masks);
+        ModuleRegistry.registerModule(KafkaConsumerConfig.CONFIG_NAME, LightConsumer.class.getName(), Config.getNoneDecryptedInstance().getJsonMapConfigNoCache(KafkaConsumerConfig.CONFIG_NAME), masks);
     }
 }
diff --git a/kafka-producer/src/main/java/com/networknt/kafka/producer/LightProducer.java b/kafka-producer/src/main/java/com/networknt/kafka/producer/LightProducer.java
@@ -43,6 +43,6 @@ default void registerModule() {
         masks.add("basic.auth.user.info");
         masks.add("sasl.jaas.config");
         masks.add("schema.registry.ssl.truststore.password");
-        ModuleRegistry.registerModule(KafkaProducerConfig.CONFIG_NAME, LightProducer.class.getName(), Config.getInstance().getJsonMapConfigNoCache(KafkaProducerConfig.CONFIG_NAME), masks);
+        ModuleRegistry.registerModule(KafkaProducerConfig.CONFIG_NAME, LightProducer.class.getName(), Config.getNoneDecryptedInstance().getJsonMapConfigNoCache(KafkaProducerConfig.CONFIG_NAME), masks);
     }
 }
diff --git a/kafka-streams/src/main/java/com/networknt/kafka/streams/LightStreams.java b/kafka-streams/src/main/java/com/networknt/kafka/streams/LightStreams.java
@@ -40,7 +40,7 @@ default void registerModule() {
         masks.add("basic.auth.user.info");
         masks.add("sasl.jaas.config");
         masks.add("schema.registry.ssl.truststore.password");
-        ModuleRegistry.registerModule(KafkaStreamsConfig.CONFIG_NAME, LightStreams.class.getName(), Config.getInstance().getJsonMapConfigNoCache(KafkaStreamsConfig.CONFIG_NAME), masks);
+        ModuleRegistry.registerModule(KafkaStreamsConfig.CONFIG_NAME, LightStreams.class.getName(), Config.getNoneDecryptedInstance().getJsonMapConfigNoCache(KafkaStreamsConfig.CONFIG_NAME), masks);
     }
 
     /**