安装Kafka
本次安装kafka使用的docker镜像是wurstmeister/kafka - Docker Hub，安装流程如下。
准备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
运行
docker-compose up -d
测试Kafka功能
使用kafkacat测试kafka是否安装成功，首先安装kafkacat:
sudo apt install kafkacat
开启kafka producer，命令行中随便输入一些字符：
$ kafkacat -P -b localhost -t mytopic
abcdefe
开启kafka consumer接收消息，控制台中收到消息如下，证明kafka正常启动运行。
$ kafkacat -b localhost -t mytopic
abcdefe
