生产者追加配置

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

Logo
魔乐社区

魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。

更多推荐

cover

替你试过了，消费级显卡可以跑的开源文生图SOTA模型，顶级渲染、高密度文本绘图

avatar 魔乐社区
cover

量化挑战赛冠军专访：4小时啃下W4A8量化，我靠的是这些经验

avatar 魔乐社区
cover

「极限压缩 量化未来」Modelers GeekDay上海站圆满落幕

avatar 魔乐社区