1、pull 

docker pull apache/kafka:4.1.2 # 稳定版

Kafka 4.1.2 不需要 ZK，直接 KRaft 模式

2、宿主机IP 192.168.91.164

      docker run  kafka1、kafka2、kafka3

 节点 1（kafka1）

docker run -d --name kafka1 -p 9092:9092 -p 9093:9093 -v /var/lib/kafka1/data:/opt/kafka/data -e KAFKA_NODE_ID=1 -e KAFKA_PROCESS_ROLES=controller,broker -e KAFKA_CONTROLLER_QUORUM_VOTERS=1@192.168.91.164:9093,2@192.168.91.164:9095,3@192.168.91.164:9097 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.91.164:9092 -e KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER -e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=3 -e KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=3 -e KAFKA_TRANSACTION_STATE_LOG_MIN_ISR=2 apache/kafka:4.1.2

节点 2（kafka2）

docker run -d --name kafka2 -p 9094:9092 -p 9095:9093 -v /var/lib/kafka2/data:/opt/kafka/data -e KAFKA_NODE_ID=2 -e KAFKA_PROCESS_ROLES=controller,broker -e KAFKA_CONTROLLER_QUORUM_VOTERS=1@192.168.91.164:9093,2@192.168.91.164:9095,3@192.168.91.164:9097 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.91.164:9094 -e KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER -e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=3 -e KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=3 -e KAFKA_TRANSACTION_STATE_LOG_MIN_ISR=2 apache/kafka:4.1.2

节点 3（kafka3）

docker run -d --name kafka3 -p 9096:9092 -p 9097:9093 -v /var/lib/kafka3/data:/opt/kafka/data -e KAFKA_NODE_ID=3 -e KAFKA_PROCESS_ROLES=controller,broker -e KAFKA_CONTROLLER_QUORUM_VOTERS=1@192.168.91.164:9093,2@192.168.91.164:9095,3@192.168.91.164:9097 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.91.164:9096 -e KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER -e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=3 -e KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=3 -e KAFKA_TRANSACTION_STATE_LOG_MIN_ISR=2 apache/kafka:4.1.2

3、验证集群

 ./kafka-metadata-quorum.sh --bootstrap-server 192.168.91.164:9092 describe --status

能看到 LeaderId 和 3 个 Voters 就说明集群正常

4、offsetExplorer客户端

5、sb-KafkaListener集群

5.1 yml