1.拉取鏡像
docker pull zookeeper
docker pull wurstmeister/kafka
2.啟動(dòng)zookeeper
docker run -d --name zookeeper -p 2181:2181 zookeeper
3.設(shè)置zookeeper容器對(duì)外服務(wù)的ip
Zookeeper_Server_IP=$(docker inspect zookeeper --format='{{ .NetworkSettings.IPAddress }}')
4.啟動(dòng)kafka
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=${Zookeeper_Server_IP}:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -e TZ="Asia/Shanghai" wurstmeister/kafka
測(cè)試生產(chǎn)者消費(fèi)者功能
-
終端進(jìn)入kafka
docker exec -it kafka bash
-
cd /opt/kafka_version/bin/
-
創(chuàng)建topic，運(yùn)行生產(chǎn)者命令
./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic first-topic
-
發(fā)送消息
-
啟動(dòng)終端進(jìn)入kafka，進(jìn)入相同目錄，運(yùn)行消費(fèi)者命令
./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic first-topic --from-beginning文章來(lái)源：http://www.zghlxwxcb.cn/news/detail-636022.html
看到消息成功接收。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-636022.html
到了這里，關(guān)于mac m1使用docker安裝kafka的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
