Skip to content

Commit 25146a7

Browse files
authored
feat: Add support for SASL/SCRAM-SHA-512 (#12)
1 parent 524f46c commit 25146a7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/devshawn/kafka/gitops/config/KafkaGitopsConfigLoader.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ private static void handleAuthentication(AtomicReference<String> username, Atomi
6161
String loginModule = null;
6262
if (config.get(SaslConfigs.SASL_MECHANISM).equals("PLAIN")) {
6363
loginModule = "org.apache.kafka.common.security.plain.PlainLoginModule";
64-
} else if (config.get(SaslConfigs.SASL_MECHANISM).equals("SCRAM-SHA-256")) {
64+
} else if (config.get(SaslConfigs.SASL_MECHANISM).equals("SCRAM-SHA-256") || config.get(SaslConfigs.SASL_MECHANISM).equals("SCRAM-SHA-512")) {
6565
loginModule = "org.apache.kafka.common.security.scram.ScramLoginModule";
6666
} else {
6767
throw new MissingConfigurationException("KAFKA_SASL_MECHANISM");

0 commit comments

Comments
 (0)