??讀完這篇文章里你能收獲到
- 在Docker中快速部署Kafka
- 在Docker中快速部署Zookeeper
- 搭建Kafka管理平臺
- Kafka部署測試
- 感謝點贊+收藏，避免下次找不到~
文章來源：http://www.zghlxwxcb.cn/news/detail-571833.html
一、部署Zookeeper
1 拉取Zookeeper鏡像
docker pull wurstmeister/zookeeper
2 運行Zookeeper
docker run --restart=always --name zookeeper \
--log-driver json-file \
--log-opt max-size=100m \
--log-opt max-file=2 \
-p 2181:2181 \
-v /etc/localtime:/etc/localtime \
-d wurstmeister/zookeeper
二、部署Kafka
1 拉取Kafka鏡像
docker pull wurstmeister/kafka
2 運行Kafka
docker run --restart=always --name kafka \
--log-driver json-file \
--log-opt max-size=100m \
--log-opt max-file=2 \
-p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=192.168.8.102:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.8.102:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
-v /etc/localtime:/etc/localtime \
-d wurstmeister/kafka
參數(shù)說明：
-e KAFKA_BROKER_ID=0 在kafka集群中，每個kafka都有一個BROKER_ID來區(qū)分自己
-e KAFKA_ZOOKEEPER_CONNECT=172.16.0.13:2181/kafka 配置zookeeper管理kafka的路徑172.16.0.13:2181/kafka
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.16.0.13:9092 把kafka的地址端口注冊給zookeeper，如果是遠程訪問要改成外網(wǎng)IP,類如Java程序訪問出現(xiàn)無法連接。
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的監(jiān)聽端口
-v /etc/localtime:/etc/localtime 容器時間同步虛擬機的時間
三、驗證是否部署成功
1 進入到kafka容器中
docker exec -it kafka /bin/sh
2 創(chuàng)建topic 生產(chǎn)者
cd opt/kafka_2.13-2.8.1
bin/kafka-topics.sh --create --zookeeper 192.168.8.102:2181 --replication-factor 1 --partitions 1 --topic partopic
3 生產(chǎn)者發(fā)送消息
bin/kafka-console-producer.sh --broker-list 192.168.8.102:9092 --topic partopic
4 消費者消費消息
- 新打開個ssh窗口
- 跟前面步驟一樣進入到容器
bin/kafka-console-consumer.sh --bootstrap-server 192.168.8.102:9092 --topic partopic --from-beginning
四、搭建kafka管理平臺
1 拉取kafka-manager鏡像
docker pull docker.io/sheepkiller/kafka-manager
2 運行kafka-manager
docker run --restart=always --name kafka-manager \
-p 9000:9000 \
-e ZK_HOSTS="192.168.8.102:2181" \
--net=host \
-d sheepkiller/kafka-manager
3 實操步驟
文章來源地址http://www.zghlxwxcb.cn/news/detail-571833.html
到了這里，關于『Kafka』在Docker中快速部署Kafka及其管理平臺搭建的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網(wǎng)！
