Node-3 (node.id=3): advertised.listeners=PLAINTEXT:\/\/kafka-node-03:9092<\/li>\n<\/ul>\n[worker@kafka-node-01 software]$ cd kafka_4.1.1\/config\/
\n[worker@kafka-node-01 config]$ vim server.properties
\n############################# KRaft \u6838\u5fc3\u914d\u7f6e #############################
\nprocess.roles=broker,controller
\n# \u3010\u5173\u952e\u3011\u6bcf\u4e2a\u8282\u70b9\u552f\u4e00：node-1=1, node-2=2, node-3=3
\nnode.id=1
\n# \u3010\u5173\u952e\u3011\u6240\u6709\u8282\u70b9\u5fc5\u987b\u5b8c\u5168\u4e00\u81f4！\u5217\u51fa\u6240\u6709Controller\u8282\u70b9
\ncontroller.quorum.voters=1@kafka-node-01:9093,2@kafka-node-02:9093,3@kafka-node-03:9093
\ncontroller.listener.names=CONTROLLER
\n############################# \u7f51\u7edc\u76d1\u542c\u5668 #############################
\n# \u5916\u90e8\u5ba2\u6237\u7aef\u8bbf\u95ee\u7aef\u53e3 (9092) \u548c Controller\u5185\u90e8\u901a\u4fe1\u7aef\u53e3 (9093)
\nlisteners=PLAINTEXT:\/\/:9092,CONTROLLER:\/\/:9093
\ninter.broker.listener.name=PLAINTEXT
\n# \u3010\u5173\u952e\u3011\u5404\u8282\u70b9\u9700\u6539\u4e3a\u81ea\u5df1\u7684\u4e3b\u673a\u540d\/IP
\nadvertised.listeners=PLAINTEXT:\/\/kafka-node-01:9092
\nlistener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
\n############################# \u6570\u636e\u4e0e\u65e5\u5fd7 #############################
\n## Kafka\u6570\u636e\u76ee\u5f55
\nlog.dirs=\/data\/kafka-logs
\nnum.partitions=3
\ndefault.replication.factor=3
\nmin.insync.replicas=2
\n############################# \u5185\u90e8Topic\u914d\u7f6e #############################
\noffsets.topic.replication.factor=3
\ntransaction.state.log.replication.factor=3
\ntransaction.state.log.min.isr=2<\/p>\n
3.\u62f7\u8d1d\u5305\u5230\u5176\u4ed6\u8282\u70b9\u4fee\u6539\u914d\u7f6e<\/h4>\n
\u5c06\u914d\u7f6e\u597d\u7684\u6587\u4ef6\u590d\u5236\u5230\u5176\u4ed6\u8282\u70b9，\u5e76\u6839\u636e\u5404\u8282\u70b9\u4fe1\u606f\u4fee\u6539\u76f8\u5e94\u7684\u914d\u7f6e\u9879\u3002\u786e\u4fdd\u96c6\u7fa4\u914d\u7f6e\u7684\u4e00\u81f4\u6027，\u540c\u65f6\u9002\u5e94\u6bcf\u4e2a\u8282\u70b9\u7684\u7279\u5b9a\u73af\u5883\u3002<\/p>\n
#\u8bbe\u7f6e\u514d\u5bc6
\n[worker@kafka-node-01 config]$ scp server.properties 172.16.130.13:`pwd`
\nserver.properties 100% 1163 4.5MB\/s 00:00
\n[worker@kafka-node-01 config]$ scp server.properties 172.16.130.15:`pwd`
\nserver.properties 100% 1163 4.3MB\/s 00:00
\n[worker@kafka-node-01 config]$
\n#\u8282\u70b9172.16.130.13
\n[worker@kafka-node-03 config]$ vim server.properties
\nnode.id=2
\nadvertised.listeners=PLAINTEXT:\/\/kafka-node-02:9092
\n#\u8282\u70b9172.16.130.15
\n[worker@kafka-node-03 config]$ vim server.properties
\nnode.id=3
\nadvertised.listeners=PLAINTEXT:\/\/kafka-node-03:9092<\/p>\n
4.\u521d\u59cb\u5316\u96c6\u7fa4<\/h4>\n
\u521d\u59cb\u5316\u662f Kafka \u96c6\u7fa4\u542f\u52a8\u524d\u7684\u5173\u952e\u6b65\u9aa4，\u5305\u62ec\u751f\u6210\u552f\u4e00\u7684\u96c6\u7fa4 ID \u548c\u683c\u5f0f\u5316\u6bcf\u4e2a\u8282\u70b9\u7684\u5b58\u50a8\u76ee\u5f55\u3002\u8fd9\u786e\u4fdd\u96c6\u7fa4\u5177\u6709\u552f\u4e00\u7684\u6807\u8bc6，\u5e76\u4e14\u6570\u636e\u76ee\u5f55\u7ed3\u6784\u6b63\u786e\u3002<\/p>\n
# 01. \u751f\u6210\u96c6\u7fa4UUID（\u4ec5\u5728\u4efb\u610f\u4e00\u4e2a\u8282\u70b9\u6267\u884c\u4e00\u6b21）
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-storage.sh random-uuid
\n# \u8f93\u51fa\u793a\u4f8b：6UlNw0IfR5-mEArqnPh1aQ<\/p>\n
# 02. \u683c\u5f0f\u5316\u5b58\u50a8\u76ee\u5f55（\u5728\u6bcf\u4e2a\u8282\u70b9\u6267\u884c，\u4f7f\u7528\u76f8\u540c\u7684UUID）
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-storage.sh format \\\\
\n -t 6UlNw0IfR5-mEArqnPh1aQ \\\\
\n -c \/data\/software\/kafka_4.1.1\/config\/server.properties<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082544-6983028825f0c.png\")
<\/p>\n
5.\u521b\u5efa\u542f\u52a8\u811a\u672c（\u6240\u6709\u8282\u70b9）<\/h4>\n
\u7f16\u5199\u7edf\u4e00\u7684\u542f\u52a8\u811a\u672c，\u89c4\u8303 Kafka \u670d\u52a1\u7684\u542f\u52a8\u3001\u505c\u6b62\u3001\u91cd\u542f\u548c\u72b6\u6001\u67e5\u770b\u64cd\u4f5c\u3002\u811a\u672c\u5305\u542b\u7528\u6237\u68c0\u67e5\u3001\u8fdb\u7a0b\u7ba1\u7406\u548c\u65e5\u5fd7\u67e5\u770b\u529f\u80fd，\u4fbf\u4e8e\u65e5\u5e38\u8fd0\u7ef4\u3002<\/p>\n
[worker@kafka-node-01 bin]$ cat kafka.sh
\n#!\/bin\/bash
\n# kafka.sh – Kafka\u542f\u52a8\u7ba1\u7406\u811a\u672c<\/p>\n
KAFKA_HOME="\/data\/software\/kafka_4.1.1"
\nKAFKA_USER="worker"
\nCONFIG="$KAFKA_HOME\/config\/server.properties"
\nPID_FILE="$KAFKA_HOME\/kafka.pid"
\nLOG_FILE="$KAFKA_HOME\/logs\/kafka.out"<\/p>\n
# JVM\u53c2\u6570（\u6839\u636e\u673a\u5668\u5185\u5b58\u8c03\u6574，\u8fd9\u91cc\u8bbe\u4e3a8GB）
\nJVM_OPTS="-Xms8g -Xmx8g"<\/p>\n
# \u68c0\u67e5\u7528\u6237
\ncheck_user() {
\n if [ "$(whoami)" != "$KAFKA_USER" ]; then
\n echo "\u9519\u8bef：\u8bf7\u4f7f\u7528 $KAFKA_USER \u7528\u6237\u8fd0\u884c\u6b64\u811a\u672c"
\n echo "\u4f7f\u7528\u65b9\u6cd5: sudo -u $KAFKA_USER $0"
\n exit 1
\n fi
\n}
\n# \u542f\u52a8Kafka
\nstart() {
\n check_user
\n if [ -f "$PID_FILE" ]; then
\n PID=$(cat "$PID_FILE")
\n if kill -0 $PID 2>\/dev\/null; then
\n echo "Kafka\u5df2\u5728\u8fd0\u884c (PID: $PID)"
\n exit 0
\n fi
\n fi<\/p>\n
echo "\u542f\u52a8Kafka…"
\n export KAFKA_HEAP_OPTS="$JVM_OPTS"
\n cd "$KAFKA_HOME"
\n nohup bin\/kafka-server-start.sh "$CONFIG" > "$LOG_FILE" 2>&1 &
\n echo $! > "$PID_FILE"
\n echo "Kafka\u5df2\u542f\u52a8，PID: $(cat $PID_FILE)"
\n}
\n# \u505c\u6b62Kafka
\nstop() {
\n check_user<\/p>\n
if [ -f "$PID_FILE" ]; then
\n PID=$(cat "$PID_FILE")
\n echo "\u505c\u6b62Kafka (PID: $PID)…"
\n "$KAFKA_HOME\/bin\/kafka-server-stop.sh"
\n sleep 5<\/p>\n
if kill -0 $PID 2>\/dev\/null; then
\n echo "\u5f3a\u5236\u7ec8\u6b62Kafka…"
\n kill -9 $PID
\n fi<\/p>\n
rm -f "$PID_FILE"
\n echo "Kafka\u5df2\u505c\u6b62"
\n else
\n echo "\u672a\u627e\u5230PID\u6587\u4ef6，\u5c1d\u8bd5\u67e5\u627eKafka\u8fdb\u7a0b…"
\n PID=$(ps aux | grep kafka | grep -v grep | grep -v "$0" | awk '{print $2}')
\n if [ -n "$PID" ]; then
\n echo "\u505c\u6b62Kafka\u8fdb\u7a0b: $PID"
\n kill $PID
\n else
\n echo "\u672a\u627e\u5230\u8fd0\u884c\u7684Kafka\u8fdb\u7a0b"
\n fi
\n fi
\n}
\n# \u91cd\u542fKafka
\nrestart() {
\n stop
\n sleep 2
\n start
\n}
\n# \u67e5\u770b\u72b6\u6001
\nstatus() {
\n if [ -f "$PID_FILE" ]; then
\n PID=$(cat "$PID_FILE")
\n if kill -0 $PID 2>\/dev\/null; then
\n echo "Kafka\u6b63\u5728\u8fd0\u884c (PID: $PID)"
\n return 0
\n else
\n echo "Kafka\u5df2\u505c\u6b62"
\n return 1
\n fi
\n else
\n echo "Kafka\u672a\u8fd0\u884c"
\n return 1
\n fi
\n}
\n# \u67e5\u770b\u65e5\u5fd7
\nlogs() {
\n if [ -f "$LOG_FILE" ]; then
\n tail -f "$LOG_FILE"
\n else
\n echo "\u65e5\u5fd7\u6587\u4ef6\u4e0d\u5b58\u5728: $LOG_FILE"
\n fi
\n}
\n# \u4f7f\u7528\u65b9\u6cd5
\nusage() {
\n echo "\u4f7f\u7528\u65b9\u6cd5: $0 {start|stop|restart|status|logs}"
\n echo " \u542f\u52a8\u7528\u6237: $KAFKA_USER"
\n echo " \u5b89\u88c5\u76ee\u5f55: $KAFKA_HOME"
\n}
\n# \u4e3b\u903b\u8f91
\ncase "$1" in
\n start)
\n start
\n ;;
\n stop)
\n stop
\n ;;
\n restart)
\n restart
\n ;;
\n status)
\n status
\n ;;
\n logs)
\n logs
\n ;;
\n *)
\n usage
\n exit 1
\n ;;
\nesac<\/p>\n
#\u8d4b\u4e88\u6267\u884c\u6743\u9650
\n[worker@kafka-node-01 bin]$ chmod u+x kafka.sh
\n#\u62f7\u8d1d\u5230\u5176\u4ed6\u8282\u70b9
\n[worker@kafka-node-01 bin]$ scp kafka.sh 172.16.130.13:`pwd`
\n[worker@kafka-node-01 bin]$ scp kafka.sh 172.16.130.15:`pwd`<\/p>\n
6.\u96c6\u7fa4\u7ba1\u7406\u811a\u672c<\/h4>\n
\u521b\u5efa\u96c6\u7fa4\u7ea7\u522b\u7684\u7ba1\u7406\u811a\u672c，\u53ef\u4ee5\u540c\u65f6\u5bf9\u591a\u4e2a\u8282\u70b9\u6267\u884c\u76f8\u540c\u7684\u64cd\u4f5c（\u542f\u52a8\u3001\u505c\u6b62\u3001\u91cd\u542f\u3001\u67e5\u770b\u72b6\u6001）\u3002\u8fd9\u5927\u5927\u7b80\u5316\u4e86\u591a\u8282\u70b9\u96c6\u7fa4\u7684\u8fd0\u7ef4\u5de5\u4f5c\u3002<\/p>\n
[worker@kafka-node-01 kafka_4.1.1]$ cat kafka-cluster-ctl.sh
\n#!\/bin\/bash
\n# Kafka\u96c6\u7fa4\u5feb\u901f\u63a7\u5236\u811a\u672c
\nNODES=("172.16.130.3" "172.16.130.13" "172.16.130.15")
\nSSH_USER="worker"
\nKAFKA_SCRIPT="\/data\/software\/kafka_4.1.1\/bin\/kafka.sh"<\/p>\n
usage() {
\n echo "Usage: $0 {start|stop|restart|status} [node_ip]"
\n echo "Example:"
\n echo " $0 start # \u542f\u52a8\u6240\u6709\u8282\u70b9"
\n echo " $0 stop 172.16.130.3 # \u505c\u6b62\u6307\u5b9a\u8282\u70b9"
\n exit 1
\n}
\nrun_command() {
\n local cmd=$1
\n local node=$2<\/p>\n
if [ -n "$node" ]; then
\n echo "[Executing on $node]"
\n ssh $SSH_USER@$node "$KAFKA_SCRIPT $cmd"
\n else
\n for node in "${NODES[@]}"; do
\n echo "[Executing on $node]"
\n ssh $SSH_USER@$node "$KAFKA_SCRIPT $cmd" &
\n done
\n wait
\n echo "All nodes processed."
\n fi
\n}
\n# \u4e3b\u903b\u8f91
\ncase $1 in
\n start|stop|restart|status)
\n run_command $1 $2
\n ;;
\n *)
\n usage
\n ;;
\nesac
\n[worker@kafka-node-01 kafka_4.1.1]$ .\/kafka-cluster-ctl.sh start<\/p>\n
\u5982\u4e0b\u56fe\u6240\u793a，\u8bf4\u660e\u6211\u4eeckafka\u96c6\u7fa4\u5df2\u7ecf\u6210\u529f\u542f\u52a8<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082544-69830288711de.png\")
<\/p>\n
7.\u6d4b\u8bd5<\/h4>\n
\u96c6\u7fa4\u542f\u52a8\u540e，\u901a\u8fc7\u521b\u5efa Topic\u3001\u67e5\u770b\u5206\u533a\u5206\u5e03\u7b49\u64cd\u4f5c\u9a8c\u8bc1\u96c6\u7fa4\u662f\u5426\u6b63\u5e38\u5de5\u4f5c\u3002\u8fd9\u662f\u90e8\u7f72\u5b8c\u6210\u540e\u5fc5\u8981\u7684\u9a8c\u8bc1\u6b65\u9aa4，\u786e\u4fdd\u96c6\u7fa4\u53ef\u4ee5\u6b63\u5e38\u63d0\u4f9b\u670d\u52a1\u3002<\/p>\n
\/data\/software\/kafka_4.1.1\/bin\/kafka-topics.sh –create \\\\
\n –topic test-prod-topic \\\\
\n –partitions 3 \\\\
\n –replication-factor 3 \\\\
\n –bootstrap-server kafka-node-01:9092<\/p>\n
# \u67e5\u770bTopic\u8be6\u60c5，\u786e\u8ba4\u5206\u533a\u5747\u5300\u5206\u5e03\u5728\u4e0d\u540cBroker\u4e0a
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-topics.sh –describe \\\\
\n –topic test-prod-topic \\\\
\n –bootstrap-server kafka-node-01:9092<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082544-698302889a235.png\")
<\/p>\n
\u56db\u3001\u5b89\u5168\u8ba4\u8bc1<\/h3>\n
\u672c\u7ae0\u8282\u4ecb\u7ecd\u5982\u4f55\u4e3a\u751f\u4ea7\u73af\u5883 Kafka \u96c6\u7fa4\u914d\u7f6e SASL\/SCRAM \u5b89\u5168\u8ba4\u8bc1\u3002\u5b89\u5168\u8ba4\u8bc1\u662f\u751f\u4ea7\u73af\u5883\u7684\u57fa\u672c\u8981\u6c42，\u53ef\u4ee5\u9632\u6b62\u672a\u6388\u6743\u8bbf\u95ee，\u4fdd\u62a4\u6570\u636e\u5b89\u5168\u3002<\/p>\n
\u5b89\u5168\u8bf4\u660e：\u751f\u4ea7\u73af\u5883\u4e2d，Kafka \u96c6\u7fa4\u5fc5\u987b\u542f\u7528\u5b89\u5168\u8ba4\u8bc1\u3002SASL\/SCRAM \u63d0\u4f9b\u4e86\u4e00\u79cd\u76f8\u5bf9\u5b89\u5168\u4e14\u652f\u6301\u52a8\u6001\u7528\u6237\u7ba1\u7406\u7684\u8ba4\u8bc1\u673a\u5236，\u9002\u5408\u5927\u591a\u6570\u751f\u4ea7\u573a\u666f\u3002<\/p>\n
1. \u52a8\u6001\u521b\u5efaSCRAM\u7528\u6237（\u96c6\u7fa4\u542f\u52a8\u540e\u6267\u884c）<\/h4>\n
\u4f7f\u7528 Kafka \u7ba1\u7406\u5de5\u5177\u52a8\u6001\u521b\u5efa SCRAM \u7528\u6237\u3002\u4e0e\u9759\u6001\u914d\u7f6e\u6587\u4ef6\u4e0d\u540c，SCRAM \u7528\u6237\u51ed\u8bc1\u5b58\u50a8\u5728 Kafka \u5185\u90e8，\u652f\u6301\u52a8\u6001\u6dfb\u52a0\u548c\u4fee\u6539，\u65e0\u9700\u91cd\u542f\u670d\u52a1\u3002<\/p>\n
# \u5728\u4efb\u4e00\u8282\u70b9，\u4f7f\u7528PLAINTEXT\u8fde\u63a5\u5148\u521b\u5efa\u7528\u6237（\u96c6\u7fa4\u5b89\u5168\u542f\u7528\u524d\u64cd\u4f5c）
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-configs.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –entity-type users –entity-name admin \\\\
\n –alter –add-config 'SCRAM-SHA-512=[password=aTu!O8jxoTH4$q%o]'<\/p>\n
#\u5b89\u5168\u542f\u52a8\u540e
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-configs.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –entity-type users –entity-name kafkaui \\\\
\n –alter –add-config 'SCRAM-SHA-512=[password=4LT%897@211uRuhO]' \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
\/data\/software\/kafka_4.1.1\/bin\/kafka-configs.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –entity-type users –entity-name kafka_canal \\\\
\n –alter –add-config 'SCRAM-SHA-512=[password=vvJ20n7j7iKv!vA4]' \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
# \u9a8c\u8bc1\u7528\u6237\u5df2\u6dfb\u52a0
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-configs.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –entity-type users –describe <\/p>\n
\u5982\u4e0b\u56fe\u6240\u793a\u8d26\u53f7\u5df2\u6210\u529f\u6dfb\u52a0<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082544-69830288d521a.png\")
<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082544-69830288f16e0.png\")
<\/p>\n
2. \u4fee\u6539server.properties\u914d\u7f6e\u6587\u4ef6（\u6240\u6709\u8282\u70b9）<\/h4>\n
\u4fee\u6539 Kafka \u670d\u52a1\u5668\u7684\u914d\u7f6e\u6587\u4ef6，\u5c06\u76d1\u542c\u5668\u534f\u8bae\u4ece PLAINTEXT \u6539\u4e3a SASL_PLAINTEXT，\u5e76\u6307\u5b9a\u4f7f\u7528 SCRAM-SHA-512 \u8ba4\u8bc1\u673a\u5236\u3002\u8fd9\u662f\u542f\u7528\u5b89\u5168\u8ba4\u8bc1\u7684\u5173\u952e\u914d\u7f6e\u3002<\/p>\n
[worker@kafka-node-01 config]$ vim server.properties
\n# ====== \u5173\u952e\u4fee\u6539\u70b9 ======
\n############################# \u7f51\u7edc\u76d1\u542c\u5668 #############################
\n# \u5916\u90e8\u5ba2\u6237\u7aef\u8bbf\u95ee\u7aef\u53e3 (9092) \u548c Controller\u5185\u90e8\u901a\u4fe1\u7aef\u53e3 (9093)
\nlisteners=SASL_PLAINTEXT:\/\/:9092,CONTROLLER:\/\/:9093
\ninter.broker.listener.name=SASL_PLAINTEXT
\n# \u3010\u5173\u952e\u3011\u5404\u8282\u70b9\u9700\u6539\u4e3a\u81ea\u5df1\u7684\u4e3b\u673a\u540d\/IP
\nadvertised.listeners=SASL_PLAINTEXT:\/\/kafka-node-01:9092
\nlistener.security.protocol.map=CONTROLLER:PLAINTEXT,SASL_PLAINTEXT:SASL_PLAINTEXT<\/p>\n
# ====== SASL \u914d\u7f6e ======
\nsasl.enabled.mechanisms=SCRAM-SHA-512
\nsasl.mechanism.inter.broker.protocol=SCRAM-SHA-512<\/p>\n
3. \u521b\u5efaJAAS\u6587\u4ef6 kafka_server_jaas.conf（\u6240\u6709\u8282\u70b9）<\/h4>\n
\u521b\u5efa JAAS \u914d\u7f6e\u6587\u4ef6，\u4e3a Kafka Broker \u63d0\u4f9b\u81ea\u8eab\u8ba4\u8bc1\u4fe1\u606f\u3002\u5728 SCRAM \u6a21\u5f0f\u4e0b，\u8be5\u6587\u4ef6\u4ec5\u5305\u542b Broker \u8fdb\u7a0b\u7528\u4e8e\u542f\u52a8\u548c\u5185\u90e8\u901a\u4fe1\u7684\u51ed\u8bc1\u3002<\/p>\n
[worker@kafka-node-01 ~]$ cat > \/data\/software\/kafka_4.1.1\/config\/kafka_server_jaas.conf << 'EOF'
\nKafkaServer {
\n org.apache.kafka.common.security.scram.ScramLoginModule required
\n username="admin"
\n password="aTu!O8jxoTH4$q%o";
\n};
\nEOF<\/p>\n
chmod 600 \/data\/software\/kafka_4.1.1\/config\/kafka_server_jaas.conf<\/p>\n
4. \u66f4\u65b0\u542f\u52a8\u6587\u4ef6<\/h4>\n
\u4fee\u6539\u542f\u52a8\u811a\u672c，\u901a\u8fc7\u73af\u5883\u53d8\u91cf\u6307\u5b9a JAAS \u914d\u7f6e\u6587\u4ef6\u7684\u8def\u5f84，\u786e\u4fdd Kafka \u8fdb\u7a0b\u542f\u52a8\u65f6\u80fd\u591f\u52a0\u8f7d\u5b89\u5168\u8ba4\u8bc1\u914d\u7f6e\u3002<\/p>\n
#\u5728\u542f\u52a8\u6587\u4ef6\u4e2d\u6dfb\u52a0\u4e0b\u9762\u4e00\u884c
\n[worker@kafka-node-01 bin]$ vim kafka.sh
\nexport KAFKA_OPTS="Djava.security.auth.login.config=\/data\/software\/kafka_4.1.1\/config\/kafka_server_jaas.conf" <\/p>\n
#\u62f7\u8d1d\u5230\u5176\u4ed6\u8282\u70b9
\n[worker@kafka-node-01 bin]$ scp kafka.sh 172.16.130.13:`pwd`
\n[worker@kafka-node-01 bin]$ scp kafka.sh 172.16.130.15:`pwd`<\/p>\n
5. \u542f\u52a8\u96c6\u7fa4<\/h4>\n
\u4f7f\u7528\u96c6\u7fa4\u7ba1\u7406\u811a\u672c\u91cd\u65b0\u542f\u52a8\u6240\u6709\u8282\u70b9，\u4f7f\u5b89\u5168\u8ba4\u8bc1\u914d\u7f6e\u751f\u6548\u3002\u91cd\u542f\u540e，\u6240\u6709\u5ba2\u6237\u7aef\u8fde\u63a5\u90fd\u9700\u8981\u63d0\u4f9b\u6b63\u786e\u7684\u8ba4\u8bc1\u4fe1\u606f\u3002<\/p>\n
[worker@kafka-node-01 kafka_4.1.1]$ .\/kafka-cluster-ctl.sh stop
\n[worker@kafka-node-01 kafka_4.1.1]$ .\/kafka-cluster-ctl.sh start<\/p>\n
6. \u5ba2\u6237\u7aef\u8fde\u63a5\u6d4b\u8bd5<\/h4>\n
\u521b\u5efa\u5ba2\u6237\u7aef\u914d\u7f6e\u6587\u4ef6，\u4f7f\u7528\u6b63\u786e\u7684\u7528\u6237\u540d\u548c\u5bc6\u7801\u8fde\u63a5\u542f\u7528\u4e86\u5b89\u5168\u8ba4\u8bc1\u7684 Kafka \u96c6\u7fa4，\u9a8c\u8bc1\u8ba4\u8bc1\u914d\u7f6e\u662f\u5426\u6b63\u786e\u3002<\/p>\n
#01 \u6dfb\u52a0\u8fde\u63a5\u914d\u7f6e
\n[worker@kafka-node-01 config]$ cat client-scram.properties
\nbootstrap.servers=kafka-node-01:9092,kafka-node-02:9092,kafka-node-03:9092
\nsecurity.protocol=SASL_PLAINTEXT
\nsasl.mechanism=SCRAM-SHA-512
\nsasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \\\\
\n username="admin" \\\\
\n password="aTu!O8jxoTH4$q%o";<\/p>\n
#02 \u8fde\u63a5\u6d4b\u8bd5
\n# 1. \u6d4b\u8bd5\u5217\u51faTopic (\u6700\u57fa\u672c\u7684\u8fde\u63a5\u548c\u8ba4\u8bc1\u6d4b\u8bd5)
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-topics.sh –list \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
# 2. \u751f\u4ea7\u4e00\u6761\u6d4b\u8bd5\u6d88\u606f
\necho "Test message via SCRAM" | \/data\/software\/kafka_4.1.1\/bin\/kafka-console-producer.sh \\\\
\n –topic test-topic \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –producer.config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
# 3. \u6d88\u8d39\u6d4b\u8bd5\u6d88\u606f
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-console-consumer.sh \\\\
\n –topic test-topic \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –from-beginning \\\\
\n –consumer.config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties \\\\
\n –timeout-ms 5000 <\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082545-69830289153c2.png\")
<\/p>\n
\u4e94\u3001\u751f\u4ea7\u8c03\u4f18<\/h3>\n1.\u64cd\u4f5c\u7cfb\u7edf\u8c03\u4f18(\u6240\u6709\u8282\u70b9)<\/h4>\n
\u4f18\u5316\u64cd\u4f5c\u7cfb\u7edf\u5185\u6838\u53c2\u6570，\u63d0\u5347\u7f51\u7edc\u6027\u80fd\u548c\u6587\u4ef6\u5904\u7406\u80fd\u529b，\u4e3a Kafka \u7684\u9ad8\u6027\u80fd\u8fd0\u884c\u63d0\u4f9b\u5e95\u5c42\u652f\u6301\u3002<\/p>\n
# \u8c03\u6574\u5185\u6838\u53c2\u6570
\n[root@kafka-node-01 kafka_4.1.1]# tee -a \/etc\/sysctl.conf << EOF
\nnet.core.rmem_default=262144
\nnet.core.wmem_default=262144
\nnet.core.rmem_max=16777216
\nnet.core.wmem_max=16777216
\nnet.ipv4.tcp_rmem=4096 87380 16777216
\nnet.ipv4.tcp_wmem=4096 65536 16777216
\nvm.swappiness=1
\nEOF
\n[root@kafka-node-01 kafka_4.1.1]# sysctl -p<\/p>\n
# \u8c03\u6574\u6587\u4ef6\u53e5\u67c4\u9650\u5236
\n[root@kafka-node-01 kafka_4.1.1]# vim \/etc\/security\/limits.conf
\n* soft nofile 655350
\n* hard nofile 655350<\/p>\n
2.Kafka\u5173\u952e\u751f\u4ea7\u53c2\u6570（\u6240\u6709\u8282\u70b9）<\/h4>\n
\u8c03\u6574 Kafka \u7684\u5173\u952e\u914d\u7f6e\u53c2\u6570，\u4f18\u5316\u7f51\u7edc\u5904\u7406\u3001\u6570\u636e\u590d\u5236\u3001\u65e5\u5fd7\u4fdd\u7559\u7b49\u65b9\u9762\u7684\u6027\u80fd，\u4ee5\u9002\u5e94\u751f\u4ea7\u73af\u5883\u7684\u9ad8\u8d1f\u8f7d\u9700\u6c42\u3002<\/p>\n
[worker@kafka-node-01 ~]$ cd \/data\/software\/kafka_4.1.1\/config\/
\n[worker@kafka-node-01 config]$ vim server.properties
\n# \u7f51\u7edc\u4e0eIO\u6027\u80fd
\n#\u7f51\u7edc\u7ebf\u7a0b\u6c60\u5927\u5c0f\u3002\u8bbe\u7f6e\u8fc7\u5c0f\u4f1a\u6210\u4e3a\u7f51\u7edc\u74f6\u9888，\u8bbe\u7f6e\u8fc7\u5927\u4f1a\u9020\u6210\u4e0d\u5fc5\u8981\u7684\u4e0a\u4e0b\u6587\u5207\u6362\u3002 \u5bf9\u4e8e\u751f\u4ea7\u73af\u5883，8-16 \u662f\u5e38\u89c1\u8303\u56f4\u3002
\nnum.network.threads=8
\n#IO \u7ebf\u7a0b\u6c60\u5927\u5c0f，\u5176\u6570\u91cf\u901a\u5e38\u914d\u7f6e\u4e3a CPU \u6838\u5fc3\u6570\u7684 1.5 \u5230 2 \u500d\u5de6\u53f3\u3002\u60a8\u914d\u7f6e\u7684 16 \u9002\u5408 8-12 \u6838\u7684\u670d\u52a1\u5668\u3002
\nnum.io.threads=16
\n#TCP \u53d1\u9001\u7f13\u51b2\u533a\u5927\u5c0f (SO_SNDBUF) \u7ea6 1 MB
\nsocket.send.buffer.bytes=1024000
\n#TCP \u63a5\u6536\u7f13\u51b2\u533a\u5927\u5c0f (SO_RCVBUF) \u7ea6 1 MB
\nsocket.receive.buffer.bytes=1024000<\/p>\n
# \u590d\u5236\u4e0e\u53ef\u7528\u6027
\n#\u662f\u5426\u5141\u8bb8\u201c\u975e\u540c\u6b65\u201d\u526f\u672c\u5f53\u9009 Leader
\nunclean.leader.election.enable=false
\n#\u526f\u672c\u6ede\u540e\u6700\u5927\u65f6\u95f4 30s
\nreplica.lag.time.max.ms=30000<\/p>\n
# \u65e5\u5fd7\u4fdd\u7559\u7b56\u7565
\n#\u57fa\u4e8e\u65f6\u95f4\u7684\u65e5\u5fd7\u4fdd\u7559\u7b56\u7565\u3002Kafka \u4f1a\u81ea\u52a8\u5220\u9664\u8d85\u8fc7 168 \u5c0f\u65f6（\u5373 7 \u5929） \u7684\u65e7\u65e5\u5fd7\u6bb5\u6587\u4ef6\u3002\u8fd9\u662f\u63a7\u5236\u6570\u636e\u4fdd\u7559\u671f\u7684\u6838\u5fc3\u53c2\u6570\u3002\u5982\u679c\u540c\u65f6\u8bbe\u7f6e\u4e86 log.retention.bytes，\u5219\u4efb\u4e00\u6761\u4ef6\u6ee1\u8db3\u65f6\u90fd\u4f1a\u89e6\u53d1\u5220\u9664.
\nlog.retention.hours=168
\n#\u57fa\u4e8e\u5206\u533a\u5927\u5c0f\u7684\u65e5\u5fd7\u4fdd\u7559\u7b56\u7565
\n#Kafka \u4f1a\u4fdd\u8bc1\u5355\u4e2a\u5206\u533a\u7684\u65e5\u5fd7\u6587\u4ef6\u603b\u5927\u5c0f\u4e0d\u8d85\u8fc7 10 GB，\u8d85\u51fa\u90e8\u5206\u4f1a\u88ab\u5220\u9664\u3002\u8fd9\u4e2a\u9650\u5236\u662f\u9488\u5bf9\u6bcf\u4e2a\u5206\u533a\u7684，\u5982\u679c\u4e00\u4e2a Topic \u6709\u591a\u4e2a\u5206\u533a，\u5219\u5176\u603b\u5b58\u50a8\u7a7a\u95f4 = 10 GB \u00d7 \u5206\u533a\u6570\u3002\u5b83\u5e38\u4e0e log.retention.hours \u7ed3\u5408\u4f7f\u7528，\u5f62\u6210\u201c\u65f6\u95f4\u6216\u7a7a\u95f4\u4efb\u4e00\u8d85\u6807\u5373\u6e05\u7406\u201d\u7684\u53cc\u91cd\u4fdd\u969c\u3002
\nlog.retention.bytes=10737418240
\n#\u65e5\u5fd7\u6bb5\u6587\u4ef6\u5927\u5c0f\u3002Kafka \u7684\u65e5\u5fd7\u5728\u7269\u7406\u4e0a\u7531\u591a\u4e2a\u201c\u6bb5\u6587\u4ef6\u201d\u7ec4\u6210\u3002\u6b64\u53c2\u6570\u89c4\u5b9a\u6bcf\u4e2a\u6bb5\u6587\u4ef6\u7684\u6700\u5927\u5927\u5c0f\u4e3a 1 GB\u3002\u5f53\u6d3b\u8dc3\u6bb5\u6587\u4ef6\u8fbe\u5230\u6b64\u5927\u5c0f\u65f6，Kafka \u4f1a\u5c06\u5176\u5173\u95ed\u5e76\u521b\u5efa\u4e00\u4e2a\u65b0\u7684\u6bb5\u6587\u4ef6\u3002\u66f4\u5927\u7684\u6bb5\u6587\u4ef6\u53ef\u4ee5\u51cf\u5c11\u6587\u4ef6\u6570\u91cf，\u63d0\u5347\u987a\u5e8fIO\u6548\u7387，\u4f46\u4f1a\u5ef6\u957f\u65e5\u5fd7\u538b\u7f29\u548c\u52a0\u8f7d\u65f6\u95f4\u3002
\nlog.segment.bytes=1073741824<\/p>\n
\u516d\u3001\u96c6\u7fa4\u5e38\u7528\u547d\u4ee4<\/h3>\n
\u672c\u7ae0\u8282\u6c47\u603b\u4e86 Kafka \u96c6\u7fa4\u8fd0\u7ef4\u4e2d\u5e38\u7528\u7684\u547d\u4ee4\u884c\u5de5\u5177\u548c\u547d\u4ee4，\u6db5\u76d6\u57fa\u7840\u64cd\u4f5c\u3001\u6d88\u8d39\u7ec4\u7ba1\u7406\u548c KRaft \u96c6\u7fa4\u72b6\u6001\u68c0\u67e5\u7b49\u3002<\/p>\n
\u547d\u4ee4\u8bf4\u660e：\u638c\u63e1 Kafka \u547d\u4ee4\u884c\u5de5\u5177\u662f\u65e5\u5e38\u8fd0\u7ef4\u7684\u57fa\u7840\u3002\u672c\u8282\u6574\u7406\u4e86\u6700\u5e38\u7528\u7684\u547d\u4ee4\u548c\u5b83\u4eec\u7684\u5178\u578b\u7528\u9014，\u5e2e\u52a9\u60a8\u5feb\u901f\u7ba1\u7406\u548c\u76d1\u63a7\u96c6\u7fa4\u3002<\/p>\n
1.\u57fa\u7840\u547d\u4ee4\u6d4b\u8bd5<\/h4>\n
Kafka \u57fa\u7840\u64cd\u4f5c\u547d\u4ee4，\u5305\u62ec Topic \u7ba1\u7406\u3001\u6d88\u606f\u751f\u4ea7\u548c\u6d88\u8d39\u7b49\u3002\u8fd9\u4e9b\u662f\u65e5\u5e38\u8fd0\u7ef4\u4e2d\u6700\u5e38\u7528\u7684\u529f\u80fd\u3002<\/p>\n
# 1. \u6d4b\u8bd5\u5217\u51faTopic (\u6700\u57fa\u672c\u7684\u8fde\u63a5\u548c\u8ba4\u8bc1\u6d4b\u8bd5)
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-topics.sh –list \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
#\u67e5\u770b\u5355\u4e2atopic\u8be6\u7ec6\u4fe1\u606f
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-topics.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –describe –topic event_es_index \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
# 2.\u521b\u5efatopic event_es_index
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-topics.sh –create \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –topic event_es_index \\\\
\n –partitions 3 \\\\
\n –replication-factor 3\\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
# 3. \u751f\u4ea7\u4e00\u6761\u6d4b\u8bd5\u6d88\u606f
\necho "Test message via SCRAM" | \/data\/software\/kafka_4.1.1\/bin\/kafka-console-producer.sh \\\\
\n –topic test-topic \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –producer.config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
# 4. \u6d88\u8d39\u6d4b\u8bd5\u6d88\u606f
\n#\u4ece\u5934\u5f00\u59cb\u6d88\u8d39
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-console-consumer.sh \\\\
\n –topic event_es_index \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –from-beginning \\\\
\n –consumer.config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties \\\\
\n –timeout-ms 5000
\n#\u6d88\u8d39\u6700\u65b0\u6d88\u606f
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-console-consumer.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –topic task_es_index \\\\
\n –property print.timestamp=true \\\\
\n –property print.key=true \\\\
\n –property print.value=true \\\\
\n –consumer.config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
2.\u6d88\u8d39\u7ec4\u547d\u4ee4<\/h4>\n
\u6d88\u8d39\u7ec4\u7ba1\u7406\u547d\u4ee4，\u7528\u4e8e\u67e5\u770b\u6d88\u8d39\u8005\u7ec4\u7684\u72b6\u6001\u3001\u504f\u79fb\u91cf\u548c\u79ef\u538b\u60c5\u51b5，\u662f\u76d1\u63a7\u6d88\u8d39\u8fdb\u5ea6\u548c\u6392\u67e5\u6d88\u8d39\u95ee\u9898\u7684\u91cd\u8981\u5de5\u5177\u3002<\/p>\n
#\u67e5\u770b\u6d88\u8d39\u8005\u7ec4
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-consumer-groups.sh –list \\\\
\n –bootstrap-server 172.16.130.3:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties
\n#\u67e5\u770b\u6d88\u8d39\u8005\u7ec4\u8be6\u7ec6\u4fe1\u606f
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-consumer-groups.sh \\\\
\n –bootstrap-server 172.16.130.3:9092 \\\\
\n –group canal_task_group –describe \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties
\n\u5173\u952e\u6307\u6807\u8bf4\u660e：
\nCURRENT-OFFSET: \u6d88\u8d39\u8005\u5f53\u524d\u6d88\u8d39\u5230\u7684\u504f\u79fb\u91cf
\nLOG-END-OFFSET: \u5206\u533a\u6700\u65b0\u6d88\u606f\u7684\u504f\u79fb\u91cf
\nLAG: \u79ef\u538b\u6d88\u606f\u6570 = LOG-END-OFFSET – CURRENT-OFFSET
\nLAG=0: \u8868\u793a\u6240\u6709\u6d88\u606f\u90fd\u5df2\u6d88\u8d39，\u65e0\u79ef\u538b<\/p>\n
3.KRaft \u6838\u5fc3\u72b6\u6001<\/h4>\n
KRaft \u6a21\u5f0f\u7279\u6709\u7684\u96c6\u7fa4\u72b6\u6001\u68c0\u67e5\u547d\u4ee4，\u7528\u4e8e\u76d1\u63a7 Controller \u96c6\u7fa4\u7684\u5065\u5eb7\u72b6\u51b5\u548c\u6570\u636e\u4e00\u81f4\u6027\u3002\u8fd9\u662f\u786e\u4fdd KRaft \u96c6\u7fa4\u6b63\u5e38\u8fd0\u884c\u7684\u5173\u952e\u3002<\/p>\n
\u8fd9\u662fKRaft\u6a21\u5f0f\u7279\u6709\u7684\u5065\u5eb7\u68c0\u67e5，\u5173\u4e4e\u96c6\u7fa4\u7684\u201c\u5927\u8111\u201d\u662f\u5426\u6b63\u5e38\u3002<\/p>\n
3.1 \u67e5\u770b\u96c6\u7fa4ID<\/h5>\n
\/data\/software\/kafka_4.1.1\/bin\/kafka-cluster.sh cluster-id \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082545-6983028940353.png\")
<\/p>\n
3.2 \u67e5\u770b\u96c6\u7fa4\u72b6\u6001\u6458\u8981<\/h5>\n
\/data\/software\/kafka_4.1.1\/bin\/kafka-metadata-quorum.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties \\\\
\n describe –status
\n#\u91cd\u70b9\u5206\u6790 describe \u547d\u4ee4\u7684\u8f93\u51fa：
\n#\u96c6\u7fa4\u6709\u552f\u4e00\u6807\u8bc6\u7b26
\nClusterId: 6UlNw0IfR5-mEArqnPh1aQ
\n# Leader\u662f\u8282\u70b92（kafka-node-02）
\nLeaderId: 2
\n#Leader\u4efb\u671f\u6b63\u5e38
\nLeaderEpoch: 6
\n#\u6570\u636e\u4e00\u81f4\u6027\u6821\u9a8c
\n#\u5df2\u63d0\u4ea4\u65e5\u5fd7\u4f4d\u7f6e
\nHighWatermark: 41620
\n#\u5173\u952e\u6307\u6807：\u6240\u6709follower\u4e0eleader\u5b8c\u5168\u540c\u6b65，\u96f6\u5ef6\u8fdf！
\nMaxFollowerLag: 0
\n# \u5ef6\u8fdf\u65f6\u95f4\u4ec5192\u6beb\u79d2，\u975e\u5e38\u4f4e
\nMaxFollowerLagTimeMs: 195
\n#\u63a7\u5236\u5668\u96c6\u7fa4\u5b8c\u6574，\u6240\u67093\u4e2acontroller\u8282\u70b9\u90fd\u5728\u7ebf\u5e76\u53c2\u4e0e\u6295\u7968
\nCurrentVoters: [{"id": 1, "endpoints": ["CONTROLLER:\/\/kafka-node-01:9093"]}, {"id": 2, "endpoints": ["CONTROLLER:\/\/kafka-node-02:9093"]}, {"id": 3, "endpoints": ["CONTROLLER:\/\/kafka-node-03:9093"]}]
\nCurrentObservers: []<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082545-698302895b9f0.png\")
<\/p>\n
3.3 \u67e5\u770b\u96c6\u7fa4\u590d\u5236\u8be6\u60c5<\/h5>\n
\/data\/software\/kafka_4.1.1\/bin\/kafka-metadata-quorum.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties \\\\
\n describe –replication –human-readable<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082545-6983028989aa7.png\")
<\/p>\n
\n\u5217\u540d\u542b\u4e49\u4f60\u7684\u72b6\u6001\u8bf4\u660e<\/tr>\n
\n\n| NodeId<\/td>\n | \u8282\u70b9ID<\/td>\n | 2,1,3<\/td>\n | \u4e09\u4e2abroker\u8282\u70b9<\/td>\n<\/tr>\n |
\n| DirectoryId<\/td>\n | \u5143\u6570\u636e\u76ee\u5f55ID<\/td>\n | AAAAAAAAAAAAAAAAAAAAAA<\/td>\n | \u6240\u6709\u8282\u70b9\u4f7f\u7528\u76f8\u540c\u7684\u5143\u6570\u636e\u76ee\u5f55<\/td>\n<\/tr>\n |
\n| LogEndOffset<\/td>\n | \u65e5\u5fd7\u7ed3\u675f\u504f\u79fb\u91cf<\/td>\n | 42152<\/td>\n | \u6240\u6709\u8282\u70b9\u65e5\u5fd7\u4f4d\u7f6e\u5b8c\u5168\u4e00\u81f4<\/td>\n<\/tr>\n |
\n| Lag<\/td>\n | \u5ef6\u8fdf\u6d88\u606f\u6570<\/td>\n | 0<\/td>\n | \u6240\u6709\u8282\u70b9\u96f6\u5ef6\u8fdf<\/td>\n<\/tr>\n |
\n| LastFetchTimestamp<\/td>\n | \u6700\u540e\u83b7\u53d6\u65f6\u95f4<\/td>\n | 21 ms \/ 294 ms \/ 295 ms<\/td>\n | \u6700\u8fd1\u4e00\u6b21\u4eceLeader\u83b7\u53d6\u6570\u636e\u7684\u65f6\u95f4<\/td>\n<\/tr>\n |
\n| LastCaughtUpTimestamp<\/td>\n | \u6700\u540e\u540c\u6b65\u65f6\u95f4<\/td>\n | 22 ms \/ 294 ms \/ 295 ms<\/td>\n | \u6700\u8fd1\u4e00\u6b21\u4e0eLeader\u540c\u6b65\u7684\u65f6\u95f4<\/td>\n<\/tr>\n |
\n| Status<\/td>\n | \u8282\u70b9\u89d2\u8272<\/td>\n | Leader\/Follower<\/td>\n | \u8282\u70b92\u662fLeader，1\u548c3\u662fFollower<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n4.\u68c0\u67e5 Broker \u4e0e\u6570\u636e\u5c42\u72b6\u6001<\/h4>\n\u68c0\u67e5 Kafka Broker \u548c\u6570\u636e\u5c42\u7684\u5065\u5eb7\u72b6\u51b5，\u5305\u62ec Broker \u662f\u5426\u5728\u7ebf\u3001\u5206\u533a\u526f\u672c\u662f\u5426\u540c\u6b65\u3001\u662f\u5426\u6709\u4e0d\u53ef\u7528\u5206\u533a\u7b49\u3002\u8fd9\u662f\u786e\u4fdd\u6570\u636e\u670d\u52a1\u6b63\u5e38\u7684\u5173\u952e\u68c0\u67e5\u3002<\/p>\n \u786e\u8ba4\u6570\u636e\u5b58\u50a8\u548c\u670d\u52a1\u7684\u201c\u80a2\u4f53\u201d\u662f\u5426\u5065\u5eb7\u3002<\/p>\n \n- \u5065\u5eb7\u6807\u5fd7：\n
\n- broker-api-versions \u6210\u529f\u8fd4\u56de\u6240\u6709\u914d\u7f6e\u7684Broker\u5730\u5740\u548c\u7248\u672c\u4fe1\u606f\u3002<\/li>\n
- –under-replicated-partitions \u547d\u4ee4\u8f93\u51fa\u4e3a\u7a7a（\u8868\u793a\u6ca1\u6709\u672a\u540c\u6b65\u7684\u526f\u672c）\u3002<\/li>\n
- –unavailable-partitions \u547d\u4ee4\u8f93\u51fa\u4e3a\u7a7a（\u8868\u793a\u6240\u6709\u5206\u533a\u90fd\u6709\u6d3b\u8dc3\u7684Leader，\u53ef\u8bfb\u5199）\u3002<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
# 1. \u68c0\u67e5\u6240\u6709Broker\u662f\u5426\u5728\u7ebf
\n \/data\/software\/kafka_4.1.1\/bin\/kafka-broker-api-versions.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties <\/p>\n # 2. \u68c0\u67e5\u6240\u6709Topic\u7684\u8be6\u7ec6\u72b6\u6001，\u91cd\u70b9\u5173\u6ce8 \u201cUnder-Replicated\u201d \u5206\u533a
\n \/data\/software\/kafka_4.1.1\/bin\/kafka-topics.sh –describe \\\\
\n –under-replicated-partitions \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties <\/p>\n # 3. \u68c0\u67e5\u662f\u5426\u6709\u79bb\u7ebf\u5206\u533a (Offline Partitions)
\n \/data\/software\/kafka_4.1.1\/bin\/kafka-topics.sh –describe \\\\
\n –unavailable-partitions \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties <\/p>\n \u4e03\u3001\u90e8\u7f72kafka-ui<\/h3>\n\u672c\u7ae0\u8282\u4ecb\u7ecd\u5982\u4f55\u90e8\u7f72 Kafka-UI，\u4e00\u4e2a\u6d41\u884c\u7684 Kafka \u96c6\u7fa4\u7ba1\u7406\u754c\u9762\u3002Kafka-UI \u63d0\u4f9b\u4e86\u56fe\u5f62\u5316\u7684\u7ba1\u7406\u754c\u9762，\u65b9\u4fbf\u67e5\u770b\u96c6\u7fa4\u72b6\u6001\u3001\u7ba1\u7406 Topic \u548c\u76d1\u63a7\u6d88\u8d39\u7ec4\u3002<\/p>\n UI\u8bf4\u660e：Kafka-UI \u662f\u4e00\u4e2a\u5f00\u6e90\u7684 Web \u7ba1\u7406\u754c\u9762，\u63d0\u4f9b\u4e86\u6bd4\u547d\u4ee4\u884c\u66f4\u76f4\u89c2\u7684\u96c6\u7fa4\u7ba1\u7406\u65b9\u5f0f\u3002\u90e8\u7f72 Kafka-UI \u53ef\u4ee5\u663e\u8457\u63d0\u9ad8\u8fd0\u7ef4\u6548\u7387\u3002<\/p>\n 1.\u4e0b\u8f7d<\/h4>\n\u4ece GitHub \u53d1\u5e03\u9875\u9762\u4e0b\u8f7d Kafka-UI \u7684 JAR \u5305\u3002\u9009\u62e9\u4e0e\u60a8\u7684\u73af\u5883\u517c\u5bb9\u7684\u7248\u672c\u3002<\/p>\n https:\/\/github.com\/provectus\/kafka-ui\/releases\/download\/v0.7.2\/kafka-ui-api-v0.7.2.jar<\/p>\n 2.\u7f16\u5199\u914d\u7f6e\u6587\u4ef6<\/h4>\n\u521b\u5efa Kafka-UI \u7684\u914d\u7f6e\u6587\u4ef6，\u6307\u5b9a\u8981\u8fde\u63a5\u7684 Kafka \u96c6\u7fa4\u5730\u5740\u3001\u5b89\u5168\u8ba4\u8bc1\u4fe1\u606f\u4ee5\u53ca Web \u670d\u52a1\u7684\u7aef\u53e3\u7b49\u3002\u6b63\u786e\u7684\u914d\u7f6e\u662f Kafka-UI \u80fd\u591f\u6b63\u5e38\u8fde\u63a5\u548c\u5c55\u793a\u96c6\u7fa4\u4fe1\u606f\u7684\u5173\u952e\u3002<\/p>\n [worker@ansible-111 kafka-ui]$ vim application.yml
\n# application.yml \u793a\u4f8b
\nkafka:
\n clusters:
\n # \u8fd9\u91cc\u5b9a\u4e49\u4f60\u7684\u7b2c\u4e00\u4e2aKRaft\u96c6\u7fa4
\n – name: kafka-prod-cluster # \u81ea\u5b9a\u4e49\u96c6\u7fa4\u540d\u79f0
\n bootstrapServers: "kafka-node-01:9092,kafka-node-02:9092,kafka-node-03:9092" #\u3010\u5173\u952e\u3011\u4f60\u7684KRaft\u96c6\u7fa4Broker\u5730\u5740[citation:1]
\n # \u6ce8\u610f：\u5bf9\u4e8eKRaft\u6a21\u5f0f，\u53ea\u9700\u914d\u7f6ebootstrapServers，\u65e0\u9700zookeeper\u914d\u7f6e[citation:1]
\n properties:
\n security.protocol: SASL_PLAINTEXT
\n sasl.mechanism: SCRAM-SHA-512
\n sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="kafkaui" password="4LT%897@211uRuhO";<\/p>\n # \u3010\u751f\u4ea7\u73af\u5883\u5efa\u8bae\u542f\u7528\u3011\u5b89\u5168\u8ba4\u8bc1\u914d\u7f6e
\nauth:
\n type: LOGIN_FORM # \u4f7f\u7528\u8868\u5355\u767b\u5f55，\u8bbe\u4e3a DISABLED \u5219\u65e0\u9700\u767b\u5f55
\nspring:
\n security:
\n user:
\n name: admin # \u767b\u5f55\u7528\u6237\u540d
\n password: jczz@1234 # \u8bbe\u7f6e\u5f3a\u5bc6\u7801[citation:1]
\n# \u670d\u52a1\u7aef\u53e3
\nserver:
\n port: 18080<\/p>\n 3.\u5728kafka\u4e2d\u6dfb\u52a0kafkaui\u7528\u6237<\/h4>\n\u4e3a Kafka-UI \u521b\u5efa\u4e00\u4e2a\u4e13\u7528\u7684\u7528\u6237，\u5e76\u6388\u4e88\u9002\u5f53\u7684\u6743\u9650\u3002\u8fd9\u9075\u5faa\u4e86\u6700\u5c0f\u6743\u9650\u539f\u5219，\u63d0\u9ad8\u5b89\u5168\u6027\u3002<\/p>\n #\u6dfb\u52a0\u7528\u6237 #\u5b89\u5168\u542f\u52a8\u540e \u521b\u5efakafkaui\u7528\u6237\u9700\u8981\u52a0–command-config\u6267\u884c\u5bc6\u94a5
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-configs.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –entity-type users –entity-name kafkaui \\\\
\n –alter –add-config 'SCRAM-SHA-512=[password=4LT%897@211uRuhO]' \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties<\/p>\n #\u4fee\u6539\u5bc6\u7801
\n\/data\/software\/kafka_4.1.1\/bin\/kafka-configs.sh \\\\
\n –bootstrap-server kafka-node-01:9092 \\\\
\n –command-config \/data\/software\/kafka_4.1.1\/config\/client-scram.properties \\\\
\n –entity-type users \\\\
\n –entity-name kafkaui \\\\
\n –alter \\\\
\n –add-config 'SCRAM-SHA-512=[password=KJB^Xde!CmFkW6bG]'<\/p>\n 4.\u6dfb\u52a0\u542f\u52a8kafka\u811a\u672c<\/h4>\n\u521b\u5efa Kafka-UI \u7684\u542f\u52a8\u811a\u672c，\u65b9\u4fbf\u670d\u52a1\u7684\u542f\u52a8\u3001\u505c\u6b62\u548c\u7ba1\u7406\u3002\u811a\u672c\u4f1a\u81ea\u52a8\u5904\u7406\u8fdb\u7a0b\u7ba1\u7406\u548c\u65e5\u5fd7\u8f93\u51fa\u3002<\/p>\n #\u542f\u52a8\u811a\u672c
\n[worker@ansible-111 kafka-ui]$ vim restart.sh
\n#!\/bin\/bash <\/p>\n pid=`ps -ef|grep kafka-ui | grep -v grep | awk '{print $2}'`
\nkill -9 $pid
\nsleep 3s<\/p>\n nohup java -jar kafka-ui-*.jar –spring.config.location=application.yml >>kafkaui.out 2>&1 &
\n[worker@ansible-111 kafka-ui]$ chmod u+x restart.sh
\n[worker@ansible-111 kafka-ui]$ .\/restart.sh
\n[worker@ansible-111 kafka-ui]$ tail -f kafkaui.out<\/p>\n \u5982\u4e0b\u56fe\u6240\u793a，kafka-ui\u5df2\u7ecf\u542f\u52a8\u6210\u529f\u4e86<\/p>\n ![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082545-69830289bd48e.png\") <\/p>\n
\u516b\u3001\u90e8\u7f72kafka-exporter<\/h3>\n\u672c\u7ae0\u8282\u4ecb\u7ecd\u5982\u4f55\u90e8\u7f72 Kafka Exporter，\u5c06 Kafka \u96c6\u7fa4\u7684\u76d1\u63a7\u6307\u6807\u66b4\u9732\u7ed9 Prometheus\u3002Kafka Exporter \u662f\u76d1\u63a7 Kafka \u96c6\u7fa4\u5065\u5eb7\u72b6\u6001\u548c\u6027\u80fd\u7684\u5173\u952e\u7ec4\u4ef6\u3002<\/p>\n \u76d1\u63a7\u8bf4\u660e：Kafka Exporter \u6536\u96c6 Kafka \u96c6\u7fa4\u7684\u5404\u79cd\u6307\u6807（\u5982 Topic \u5206\u533a\u6570\u3001\u6d88\u8d39\u7ec4\u5ef6\u8fdf\u3001Broker \u72b6\u6001\u7b49），\u5e76\u901a\u8fc7 HTTP \u7aef\u70b9\u66b4\u9732\u7ed9 Prometheus，\u4fbf\u4e8e\u96c6\u4e2d\u76d1\u63a7\u548c\u544a\u8b66\u3002<\/p>\n 1.\u4e0b\u8f7d<\/h4>\n\u4ece GitHub \u53d1\u5e03\u9875\u9762\u4e0b\u8f7d Kafka Exporter \u7684\u4e8c\u8fdb\u5236\u5305\u3002\u9009\u62e9\u4e0e\u60a8\u7684\u7cfb\u7edf\u67b6\u6784\u5339\u914d\u7684\u7248\u672c\u3002<\/p>\n https:\/\/github.com\/danielqsj\/kafka_exporter\/releases\/download\/v1.9.0\/kafka_exporter-1.9.0.linux-arm64.tar.gz<\/p>\n 2.\u89e3\u538b\u90e8\u7f72<\/h4>\n\u89e3\u538b\u4e0b\u8f7d\u7684\u538b\u7f29\u5305，\u5e76\u5c06\u53ef\u6267\u884c\u6587\u4ef6\u79fb\u52a8\u5230\u5408\u9002\u7684\u4f4d\u7f6e，\u51c6\u5907\u914d\u7f6e\u548c\u542f\u52a8\u3002<\/p>\n tar xf kafka_exporter-1.9.0.linux-arm64.tar.gz
\nmv kafka_exporter-1.9.0.linux-arm64 kafka_exporter
\nmv kafka_exporter \/usr\/local\/<\/p>\n 3.\u914d\u7f6e\u542f\u52a8\u6587\u4ef6<\/h4>\n\u521b\u5efa Systemd \u670d\u52a1\u6587\u4ef6，\u914d\u7f6e Kafka Exporter \u7684\u542f\u52a8\u53c2\u6570，\u5305\u62ec\u8981\u76d1\u63a7\u7684 Kafka \u96c6\u7fa4\u5730\u5740\u3001\u5b89\u5168\u8ba4\u8bc1\u4fe1\u606f\u4ee5\u53ca\u76d1\u542c\u7684\u7aef\u53e3\u3002\u7136\u540e\u542f\u52a8\u670d\u52a1\u5e76\u8bbe\u7f6e\u5f00\u673a\u81ea\u542f\u3002<\/p>\n # 01. \u521b\u5efa\u7cfb\u7edf\u670d\u52a1\u6587\u4ef6
\n[root@ansible-111 worker]# cat \/etc\/systemd\/system\/kafka-exporter.service
\n[Unit]
\nDescription=Kafka Exporter for Prometheus
\nDocumentation=https:\/\/github.com\/danielqsj\/kafka_exporter
\nAfter=network.target
\n[Service]
\nUser=worker
\nGroup=worker
\nWorkingDirectory=\/usr\/local\/kafka_exporter
\nExecStart=\/usr\/local\/kafka_exporter\/kafka_exporter \\\\
\n –kafka.server=172.16.130.3:9092 \\\\
\n –kafka.server=172.16.130.13:9092 \\\\
\n –kafka.server=172.16.130.15:9092 \\\\
\n –kafka.version=4.1.1 –web.listen-address=:9308 \\\\
\n –log.level=info –sasl.enabled \\\\
\n –sasl.mechanism=scram-sha512 \\\\
\n –sasl.username=admin \\\\
\n –sasl.password='aTu!O8jxoTH4$q%%o'
\nRestart=always
\nRestartSec=5<\/p>\n [Install]
\nWantedBy=multi-user.target<\/p>\n # 02. \u91cd\u8f7d\u7cfb\u7edf\u670d\u52a1\u5e76\u542f\u52a8
\nsystemctl daemon-reload
\nsystemctl start kafka-exporter
\nsystemctl enable kafka-exporter<\/p>\n # 03. \u9a8c\u8bc1\u8fd0\u884c\u72b6\u6001（\u8f93\u51fa active (running) \u5219\u6b63\u5e38）
\nsystemctl status elasticsearch-exporter
\njournalctl -u kafka-exporter -f<\/p>\n # 04. \u9a8c\u8bc1\u6307\u6807\u63a5\u53e3（\u8fd4\u56de es_ \u5f00\u5934\u7684\u6307\u6807\u5219\u8bf4\u660e\u91c7\u96c6\u6210\u529f）
\ncurl http:\/\/172.16.130.111:9308\/metrics<\/p>\n \u4e5d\u3001\u603b\u7ed3<\/h3>\n\u672c\u6587\u8be6\u7ec6\u4ecb\u7ecd\u4e86 Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u7684\u5b8c\u6574\u90e8\u7f72\u6d41\u7a0b，\u4ece\u73af\u5883\u89c4\u5212\u3001\u96c6\u7fa4\u90e8\u7f72\u3001\u5b89\u5168\u8ba4\u8bc1\u5230\u76d1\u63a7\u7ba1\u7406，\u6db5\u76d6\u4e86\u751f\u4ea7\u73af\u5883\u6240\u9700\u7684\u5404\u4e2a\u73af\u8282\u3002\u901a\u8fc7\u9075\u5faa\u672c\u6307\u5357，\u60a8\u53ef\u4ee5\u6784\u5efa\u4e00\u4e2a\u9ad8\u53ef\u7528\u3001\u5b89\u5168\u4e14\u6613\u4e8e\u7ef4\u62a4\u7684 Kafka \u96c6\u7fa4\u3002<\/p>\n \u5173\u952e\u8981\u70b9\u603b\u7ed3：<\/p>\n \n- \u67b6\u6784\u8bbe\u8ba1：\u91c7\u7528 3 \u8282\u70b9 KRaft \u6a21\u5f0f，\u5b9e\u73b0\u9ad8\u53ef\u7528\u548c\u53bb ZooKeeper \u4f9d\u8d56\u3002\u5408\u7406\u8bbe\u7f6e\u526f\u672c\u56e0\u5b50\u548c\u6700\u5c0f\u540c\u6b65\u526f\u672c，\u786e\u4fdd\u6570\u636e\u5b89\u5168\u3002<\/li>\n
- \u5b89\u5168\u8ba4\u8bc1：\u542f\u7528 SASL\/SCRAM \u8ba4\u8bc1，\u4e3a\u4e0d\u540c\u5e94\u7528\u521b\u5efa\u4e13\u7528\u7528\u6237，\u9075\u5faa\u6700\u5c0f\u6743\u9650\u539f\u5219\u3002\u52a8\u6001\u7528\u6237\u7ba1\u7406\u63d0\u9ad8\u4e86\u8fd0\u7ef4\u7075\u6d3b\u6027\u3002<\/li>\n
- \u6027\u80fd\u8c03\u4f18：\u6839\u636e\u786c\u4ef6\u8d44\u6e90\u548c\u4e1a\u52a1\u9700\u6c42\u8c03\u6574\u64cd\u4f5c\u7cfb\u7edf\u53c2\u6570\u548c Kafka \u914d\u7f6e，\u4f18\u5316\u96c6\u7fa4\u6027\u80fd\u3002<\/li>\n
- \u8fd0\u7ef4\u5de5\u5177：\u63d0\u4f9b\u96c6\u7fa4\u7ba1\u7406\u811a\u672c\u3001\u5e38\u7528\u547d\u4ee4\u884c\u5de5\u5177，\u90e8\u7f72 Kafka-UI \u548c Kafka Exporter，\u7b80\u5316\u65e5\u5e38\u8fd0\u7ef4\u548c\u76d1\u63a7\u3002<\/li>\n
- \u5065\u5eb7\u68c0\u67e5：\u638c\u63e1 KRaft \u96c6\u7fa4\u72b6\u6001\u68c0\u67e5\u548c\u6570\u636e\u5c42\u5065\u5eb7\u68c0\u67e5\u65b9\u6cd5，\u786e\u4fdd\u96c6\u7fa4\u7a33\u5b9a\u8fd0\u884c\u3002<\/li>\n<\/ul>\n
\u901a\u8fc7\u672c\u6307\u5357\u7684\u5b9e\u8df5，\u60a8\u4e0d\u4ec5\u80fd\u591f\u6210\u529f\u90e8\u7f72 Kafka \u96c6\u7fa4，\u8fd8\u80fd\u591f\u5efa\u7acb\u4e00\u5957\u5b8c\u6574\u7684\u8fd0\u7ef4\u4f53\u7cfb，\u4e3a\u4e1a\u52a1\u63d0\u4f9b\u53ef\u9760\u7684\u6d88\u606f\u670d\u52a1\u57fa\u7840\u3002\u5efa\u8bae\u5728\u751f\u4ea7\u73af\u5883\u4e2d\u7ed3\u5408\u5177\u4f53\u7684\u4e1a\u52a1\u573a\u666f\u548c\u6027\u80fd\u6d4b\u8bd5，\u8fdb\u4e00\u6b65\u8c03\u6574\u548c\u4f18\u5316\u76f8\u5173\u53c2\u6570\u3002<\/p>\n","protected":false},"excerpt":{"rendered":" \u672c\u6587\u63d0\u4f9b Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u7684\u5b8c\u6574\u90e8\u7f72\u6307\u5357，\u6db5\u76d6\u4ece\u96c6\u7fa4\u89c4\u5212\u3001\u73af\u5883\u51c6\u5907\u3001KRaft\u6a21\u5f0f\u914d\u7f6e\u3001\u5b89\u5168\u8ba4\u8bc1\u5230\u76d1\u63a7\u7ba1\u7406\u7684\u5168\u6d41\u7a0b\u3002\u91cd\u70b9\u4ecb\u7ecd\u5982\u4f55\u5728\u751f\u4ea7\u73af\u5883\u4e2d\u6784\u5efa\u9ad8\u53ef\u7528\u3001\u5b89\u5168\u7684 Kafka \u96c6\u7fa4，\u5305\u62ec\u96c6\u7fa4\u67b6\u6784\u8bbe\u8ba1\u3001\u6027\u80fd\u8c03\u4f18\u3001\u5065\u5eb7\u76d1\u63a7\u7b49\u5173\u952e\u73af\u8282\u3002\u9002\u7528\u4e8e\u9700\u8981\u6784\u5efa\u4f01\u4e1a\u7ea7\u6d88\u606f\u4e2d\u95f4\u4ef6\u5e73\u53f0\u7684\u6280\u672f\u56e2\u961f\u3002
\n\u4e00\u3001\u751f\u4ea7\u73af\u5883\u89c4\u5212\u4e0e\u8bbe\u8ba1
\n\u672c\u7ae0\u8282\u4ecb\u7ecd\u751f\u4ea7\u73af\u5883\u4e2d Kafka \u96c6\u7fa4\u7684\u89c4\u5212\u4e0e\u8bbe\u8ba1\u539f\u5219，\u5305\u62ec\u96c6\u7fa4\u89c4\u6a21\u3001\u67b6\u6784\u62d3\u6251\u3001\u5173\u952e\u53c2\u6570\u914d\u7f6e\u4ee5\u53ca\u751f\u4ea7\u73af\u5883\u4e0e\u5355\u673a\u90e8\u7f72\u7684\u6838\u5fc3\u5dee\u5f02<\/p>\n","protected":false},"author":2,"featured_media":71940,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[1114,664],"topic":[],"class_list":["post-71952","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-kafka","tag-664"],"yoast_head":"\n Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u90e8\u7f72\u5b8c\u6574\u6307\u5357\uff08\u624b\u628a\u624b\u6559\u7a0b\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/71952.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u90e8\u7f72\u5b8c\u6574\u6307\u5357\uff08\u624b\u628a\u624b\u6559\u7a0b\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u672c\u6587\u63d0\u4f9b Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u7684\u5b8c\u6574\u90e8\u7f72\u6307\u5357，\u6db5\u76d6\u4ece\u96c6\u7fa4\u89c4\u5212\u3001\u73af\u5883\u51c6\u5907\u3001KRaft\u6a21\u5f0f\u914d\u7f6e\u3001\u5b89\u5168\u8ba4\u8bc1\u5230\u76d1\u63a7\u7ba1\u7406\u7684\u5168\u6d41\u7a0b\u3002\u91cd\u70b9\u4ecb\u7ecd\u5982\u4f55\u5728\u751f\u4ea7\u73af\u5883\u4e2d\u6784\u5efa\u9ad8\u53ef\u7528\u3001\u5b89\u5168\u7684 Kafka \u96c6\u7fa4，\u5305\u62ec\u96c6\u7fa4\u67b6\u6784\u8bbe\u8ba1\u3001\u6027\u80fd\u8c03\u4f18\u3001\u5065\u5eb7\u76d1\u63a7\u7b49\u5173\u952e\u73af\u8282\u3002\u9002\u7528\u4e8e\u9700\u8981\u6784\u5efa\u4f01\u4e1a\u7ea7\u6d88\u606f\u4e2d\u95f4\u4ef6\u5e73\u53f0\u7684\u6280\u672f\u56e2\u961f\u3002 \u4e00\u3001\u751f\u4ea7\u73af\u5883\u89c4\u5212\u4e0e\u8bbe\u8ba1 \u672c\u7ae0\u8282\u4ecb\u7ecd\u751f\u4ea7\u73af\u5883\u4e2d Kafka \u96c6\u7fa4\u7684\u89c4\u5212\u4e0e\u8bbe\u8ba1\u539f\u5219，\u5305\u62ec\u96c6\u7fa4\u89c4\u6a21\u3001\u67b6\u6784\u62d3\u6251\u3001\u5173\u952e\u53c2\u6570\u914d\u7f6e\u4ee5\u53ca\u751f\u4ea7\u73af\u5883\u4e0e\u5355\u673a\u90e8\u7f72\u7684\u6838\u5fc3\u5dee\u5f02\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/71952.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-02-04T08:25:46+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082541-698302856503f.png\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"12 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/71952.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/71952.html\",\"name\":\"Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u90e8\u7f72\u5b8c\u6574\u6307\u5357\uff08\u624b\u628a\u624b\u6559\u7a0b\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-02-04T08:25:46+00:00\",\"dateModified\":\"2026-02-04T08:25:46+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/71952.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/71952.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/71952.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u90e8\u7f72\u5b8c\u6574\u6307\u5357\uff08\u624b\u628a\u624b\u6559\u7a0b\uff09\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u90e8\u7f72\u5b8c\u6574\u6307\u5357\uff08\u624b\u628a\u624b\u6559\u7a0b\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/71952.html","og_locale":"zh_CN","og_type":"article","og_title":"Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u90e8\u7f72\u5b8c\u6574\u6307\u5357\uff08\u624b\u628a\u624b\u6559\u7a0b\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u672c\u6587\u63d0\u4f9b Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u7684\u5b8c\u6574\u90e8\u7f72\u6307\u5357，\u6db5\u76d6\u4ece\u96c6\u7fa4\u89c4\u5212\u3001\u73af\u5883\u51c6\u5907\u3001KRaft\u6a21\u5f0f\u914d\u7f6e\u3001\u5b89\u5168\u8ba4\u8bc1\u5230\u76d1\u63a7\u7ba1\u7406\u7684\u5168\u6d41\u7a0b\u3002\u91cd\u70b9\u4ecb\u7ecd\u5982\u4f55\u5728\u751f\u4ea7\u73af\u5883\u4e2d\u6784\u5efa\u9ad8\u53ef\u7528\u3001\u5b89\u5168\u7684 Kafka \u96c6\u7fa4，\u5305\u62ec\u96c6\u7fa4\u67b6\u6784\u8bbe\u8ba1\u3001\u6027\u80fd\u8c03\u4f18\u3001\u5065\u5eb7\u76d1\u63a7\u7b49\u5173\u952e\u73af\u8282\u3002\u9002\u7528\u4e8e\u9700\u8981\u6784\u5efa\u4f01\u4e1a\u7ea7\u6d88\u606f\u4e2d\u95f4\u4ef6\u5e73\u53f0\u7684\u6280\u672f\u56e2\u961f\u3002 \u4e00\u3001\u751f\u4ea7\u73af\u5883\u89c4\u5212\u4e0e\u8bbe\u8ba1 \u672c\u7ae0\u8282\u4ecb\u7ecd\u751f\u4ea7\u73af\u5883\u4e2d Kafka \u96c6\u7fa4\u7684\u89c4\u5212\u4e0e\u8bbe\u8ba1\u539f\u5219，\u5305\u62ec\u96c6\u7fa4\u89c4\u6a21\u3001\u67b6\u6784\u62d3\u6251\u3001\u5173\u952e\u53c2\u6570\u914d\u7f6e\u4ee5\u53ca\u751f\u4ea7\u73af\u5883\u4e0e\u5355\u673a\u90e8\u7f72\u7684\u6838\u5fc3\u5dee\u5f02","og_url":"https:\/\/www.wsisp.com\/helps\/71952.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-02-04T08:25:46+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082541-698302856503f.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"12 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/71952.html","url":"https:\/\/www.wsisp.com\/helps\/71952.html","name":"Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u90e8\u7f72\u5b8c\u6574\u6307\u5357\uff08\u624b\u628a\u624b\u6559\u7a0b\uff09 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-02-04T08:25:46+00:00","dateModified":"2026-02-04T08:25:46+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/71952.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/71952.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/71952.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"Kafka 4.1.1 \u751f\u4ea7\u96c6\u7fa4\u90e8\u7f72\u5b8c\u6574\u6307\u5357\uff08\u624b\u628a\u624b\u6559\u7a0b\uff09"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/71952","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=71952"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/71952\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/71940"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=71952"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=71952"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=71952"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=71952"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}} |
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082541-698302856503f.png\")
<\/p>\n![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204082543-69830287e3c15.png\")
<\/p>\n