事先声明,有版本的问题,修改之前请备份好原配置文件在修改!!!
1.先找到该文件
在这里插入图片描述

添加以下内容

 
# 添加下面的配置  ip和端口改成自己需要
listeners=SASL_PLAINTEXT://xx.xx.xx.xx:8123
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN

接下来创建一个文件,文件名为 kafka_server_jaas.conf

KafkaServer {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="kafka"
    password="admin"
    user_kafka="kafkapswd"
    user_zhb="123456";
};
#其中username和password用于brokers和zk进行认证,user_*用于zk client与zk server进行认证
#user_zhb="123456" 表示 zhb为用户名,123456为密码

接下来添加kafka_client_jaas.conf文件并写入以下内容

KafkaClient {
        org.apache.kafka.common.security.plain.PlainLoginModule required
        username="zhb"
        password="123456";
};

接下来是重点,修改kafka的启动文件kafka-server-start.sh

if [ "x$KAFKA_OPTS"  ]; then
    export KAFKA_OPTS="-Djava.security.auth.login.config=D:\消息队列\kafka_2.11-2.3.1\config\kafka_server_jaas.conf"
fi

收工完事

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐