容器化部署Kafka的最佳实践：基于KRaft模式的无ZooKeeper方案
一、docker 部署kafka单节点
1.1安装docker
可以参考这篇CentOS 7安装docker并配置镜像加速
1.3 运行kafka（注意修改zookeeper，kafka地址）
docker run -d --name kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.16.10.180:9092 -p 9092:9092 -v /home/application/Middleware/kafka/data:/var/lib/kafka/data --restart=always docker.cnb.cool/srebro/docker-images/kafka-kraft:3.7.2
1.4 登录kafka容器，创建topic
docker exec -it kafka bash
cd /opt/kafka/bin./kafka-topics.sh --create --topic my_topic_srebro.cn --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
1.5 登录kafka容器，启动一个生产者
docker exec -it kafka bash
cd /opt/kafka/bin./kafka-console-producer.sh --topic my_topic_srebro.cn --bootstrap-server localhost:9092
1.6 新开一个终端窗口，登录kafka容器，启动一个消费者
docker exec -it kafka bash
cd /opt/kafka/bin./kafka-console-consumer.sh --topic my_topic_srebro.cn --bootstrap-server localhost:9092 --from-beginning1.7 模拟在生产者上，测试几条数据，观察消费者上有没有收到数据
1.8 kafka map 管理工具
A beautiful, concise and powerful kafka web management tool. 一个美观简洁且强大的kafka web管理工具。
- 官方帮助手册： https://github.com/dushixiang/kafka-map/blob/master/README-zh_CN.md
docker run -d \-p 8080:8080 \-v /opt/kafka-map/data:/usr/local/kafka-map/data \-e DEFAULT_USERNAME=admin \-e DEFAULT_PASSWORD=admin \--name kafka-map \--restart always dushixiang/kafka-map:latest
二、docker-compose 部署kafka单节点
2.1 安装docker-compose
可以参考这篇Cenotos7 安装docker-compose
2.2 编排docker-compose文件
注意先要创建docker 单独的网络
创建自定义网络 ： docker network create -d bridge --subnet “192.168.10.0/24” --gateway “192.168.10.1” srebro.cn
version: '3'services:kafka:image: docker.cnb.cool/srebro/docker-images/kafka-kraft:3.7.2container_name: kafkanetworks:- srebro.cnenvironment:#KAFKA_LISTENERS: PLAINTEXT://:9092 # Kafka 监听端口配置KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://172.16.10.180:9092 # Kafka 对外公布的地址#KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT # 监听器与安全协议的映射#KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT # Broker 间通信使用的监听器ports:- "9092:9092"volumes:- /home/application/Middleware/kafka/data:/var/lib/kafka/datarestart: alwayskafka-map: #image: dushixiang/kafka-map:latestimage: docker.cnb.cool/srebro/docker-images/dushixiang-kafka-map:latest #加速地址container_name: kafka-mapnetworks:- srebro.cnvolumes:- "/home/application/Middleware/kafka/kafka-map/data:/usr/local/kafka-map/data" ports:- 19006:8080environment:DEFAULT_USERNAME: adminDEFAULT_PASSWORD: 123456depends_on:- kafkarestart: 'unless-stopped'networks:srebro.cn:external: true