# 下載文件
wget https://downloads.apache.org/kafka/3.5.1/kafka_2.12-3.5.1.tgz

# 文件解壓縮
tar -zxvf kafka_2.12-3.5.1.tgz

# 修改目錄名稱
mv kafka_2.12-3.5.1 kafka_2.12

# 進(jìn)入目錄
cd kafka_2.12

# 編輯 zookeeper 配置文件
vim config/zookeeper.properties

dataDir=/tmp/zookeeper
# the port at which the clients will connect
clientPort=2181
# disable the per-ip limit on the number of connections since this is a non-production config
maxClientCnxns=0
# Disable the adminserver by default to avoid port conflicts.
# Set the port to something non-conflicting if choosing to enable this
admin.enableServer=false
# admin.serverPort=8080
authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
requireClientAuthScheme=sasl
jaasLoginRenew=3600000

# 身份驗證提供程序
authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider

# 需要客戶端身份驗證方案
requireClientAuthScheme=sasl

# jaas登錄續(xù)訂
jaasLoginRenew=3600000

# 配置JAAS文件
cat > config/zookeeper_jaas.conf << EOF
Server {
    org.apache.kafka.common.security.plain.PlainLoginModule required 
    username="admin" 
    password="admin-2022" 
    user_kafka="kafka-2022" 
    user_producer="producer-2022";
};
EOF

# 編輯啟動腳本
vim bin/zookeeper-server-start.sh

export KAFKA_OPTS="-Djava.security.auth.login.config=/usr/local/kafka_2.12/config/zookeeper_jaas.conf"

# 編輯 Kafka 配置文件
vim config/server.properties

listeners=SASL_PLAINTEXT://0.0.0.0:9092
advertised.listeners=SASL_PLAINTEXT://192.168.1.95:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN

# 完成身份驗證的類
authorizer.class.name=kafka.security.authorizer.AclAuthorizer
# 如果沒有找到ACL（訪問控制列表）配置，則允許任何操作。
allow.everyone.if.no.acl.found=false
# 需要開啟設(shè)置超級管理員,設(shè)置admin用戶為超級管理員
super.users=User:admin

# 配置JAAS文件
cat > config/kafka_server_jaas.conf << EOF
KafkaServer {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="admin"
    password="admin-secret"
    user_admin="admin-secret"
    user_alice="secret";
};
KafkaClient {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="kafka"
    password="kafka-2022";
};
EOF

# 編輯啟動腳本
vim bin/kafka-server-start.sh

if [ "x$KAFKA_OPTS"  ]; then
    export KAFKA_OPTS="-Djava.security.auth.login.config=/usr/local/kafka_2.12/config/kafka_server_jaas.conf"
fi

# 執(zhí)行啟動 zookeeper 命令
./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

# 執(zhí)行啟動 kafka 命令
./bin/kafka-server-start.sh  -daemon config/server.properties