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
引入附件
System.setProperty("java.security.auth.login.config", "classpath:kafka_client_jaas.conf");
propsMap.put("security.protocol", "SASL_PLAINTEXT");
propsMap.put("sasl.mechanism", "PLAIN");
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
引入附件
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";
};
kafka实现SASL_PLAINTEXT权限认证·集成springboot篇
原文：https://www.cnblogs.com/chenandy/p/11846840.html