场景
部分场景会指定使用某一kafka 来提高安全性，这里就不得不使用用户密码认证方式等来控制文章来源地址https://www.toymoban.com/news/detail-784049.html
方法示例
// 手动加载配置信息
private Map<String, Object> consumerConfigs() {
Map<String, Object> props = new HashMap<>();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, serverUrl);
props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, enableAutoCommit);
props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, autoOffsetReset);
// 用户密码 以及认证方式等配置的加载方式
if (StringUtils.isNotEmpty(username)) {
String jaasTemplate =
"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"%s\" %s=\"%s\";";
String jaasCfg = String.format(jaasTemplate, username, "password", password);
props.put("sasl.mechanism",StringUtils.isNotEmpty(saslMechanism) ? saslMechanism : "PLAIN");
props.put("security.protocol",StringUtils.isNotEmpty(securityProtocol) ? securityProtocol : "SASL_PLAINTEXT");
props.put("sasl.jaas.config", jaasCfg);
}
return props;
}
文章来源：https://www.toymoban.com/news/detail-784049.html
到了这里，关于手动配置 kafka 用户密码，认证方式等的方式的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
![[zookeeper] SASL(Simple Authentication and Security Layer) 用户名密码认证配置](https://imgs.yssmx.com/Uploads/2024/02/686657-1.png)
