Step 1: 安装
Kafka 使用 ZooKeeper 如果你还没有ZooKeeper服务器，我们需要安装ZooKeeper服务器。
拉去 ZooKeeper
docker pull zookeeper:latest
现在启动Kafka服务器：
docker run -d--name zookeeper --publish2181:2181 --volume /etc/localtime:/etc/localtime zookeeper:latest
安装Kafka
docker pull wurstmeister/kafka:latest
启动Kafka
docker run -d--name kafka -p9092:9092 -eKAFKA_BROKER_ID=0-eKAFKA_ZOOKEEPER_CONNECT=【ZooKeeper地址】:2181 -eKAFKA_ADVERTISED_LISTENERS=PLAINTEXT://【kafka地址】:9092 -eKAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka
Step 2: 进入容器
`docker exec -it ${CONTAINER ID} /bin/bash
Step 3: 创建一个 topic
`cd /opt/kafka_**
让我们创建一个名为“test”的topic，它有一个分区和一个副本：
`bin/kafka-topics.sh --create --zookeeper zookeeper服务的地址:2181 --replication-factor 1 --partitions 1 --topic test
现在我们可以运行list（列表）命令来查看这个topic：
bin/kafka-topics.sh --list --zookeeper kafka地址:2181
Step 4: 发送消息
bin/kafka-console-producer.sh --broker-list kafka地址:9092 --topic test
Step 5: 启动一个 consumer
Kafka 还有一个命令行consumer（消费者），将消息转储到标准输出
bin/kafka-console-consumer.sh --bootstrap-server kafka地址:9092 --topic test --from-beginning
