安裝Kafka
本次安裝kafka使用的docker鏡像是wurstmeister/kafka - Docker Hub萨驶,安裝流程如下谨娜。
準(zhǔn)備docker-compose.yml
文件:
version: '2'
services:
zookeeper:
image: zookeeper
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka
ports:
- "9092:9092"
environment:
KAFKA_ADVERTISED_HOST_NAME: 192.168.1.102
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
volumes:
- /var/run/docker.sock:/var/run/docker.sock
運(yùn)行
docker-compose up -d
測試Kafka功能
使用kafkacat測試kafka是否安裝成功赠堵,首先安裝kafkacat:
sudo apt install kafkacat
開啟kafka producer碾褂,命令行中隨便輸入一些字符:
$ kafkacat -P -b localhost -t mytopic
abcdefe
開啟kafka consumer接收消息榆俺,控制臺(tái)中收到消息如下骑歹,證明kafka正常啟動(dòng)運(yùn)行预烙。
$ kafkacat -b localhost -t mytopic
abcdefe