kafka实现SASL_PLAINTEXT权限认证·集成springboot篇
时间：2019-11-13 10:20:29
收藏：0
阅读：1984
生产者追加配置
1、配置文件application.properties
kafka.producer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer kafka.producer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer kafka.producer.properties.security.protocol=SASL_PLAINTEXT kafka.producer.properties.sasl.mechanism=PLAIN
2、Configuration.java
引入附件
System.setProperty("java.security.auth.login.config", "classpath:kafka_client_jaas.conf");
propsMap.put("security.protocol", "SASL_PLAINTEXT");
propsMap.put("sasl.mechanism", "PLAIN");
消费者追加配置
1、配置文件application.properties
kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer kafka.consumer.properties.security.protocol=SASL_PLAINTEXT kafka.consumer.properties.sasl.mechanism=PLAIN
2、Configuration.java
引入附件
System.setProperty("java.security.auth.login.config", "classpath:kafka_client_jaas.conf");
propsMap.put("security.protocol", "SASL_PLAINTEXT");
propsMap.put("sasl.mechanism", "PLAIN");
=================================================================================
kafka_client_jaas.conf 文件如下
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin";
};
kafka_server_jaas.conf 文件如下
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin"
user_admin="admin"
user_alice="alice";
};
原文：https://www.cnblogs.com/chenandy/p/11846840.html
评论（0）