先起 zookeeper ，依赖
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
再起kafka
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.0.105:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.0.105:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
其中192.168.0.105是本机IP
查看docker 已经起来了
进入kafka，测试消息
docker exec -it kafka bash
创建（连接）topic，test
cd /opt/kafka_2.13-2.8.1/bin/ ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
发消息
收消息
cd /opt/kafka_2.13-2.8.1/bin/ ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
查看zookeeper
docker exec -it zookeeper bash
连接zk，查看内容
./bin/zkCli.sh
获取内容
查看zk，kfk上的topic，做删除等动作
查zk上的topic
./kafka-topics.sh --list --zookeeper 192.168.0.105:2181
删除
./kafka-topics.sh --delete --topic test --zookeeper 192.168.0.105:2181
查kfk上的topic
./kafka-topics.sh --list --bootstrap-server localhost:9092
删除
./kafka-topics.sh --delete --topic test --bootstrap-server localhost:9092性能测试
生产者
bin/kafka-producer-perf-test.sh --topic test --num-records 100 --record-size 1 --throughput 100 --producer-props bootstrap.servers=localhost:9092 bin/kafka-producer-perf-test.sh --topic test --num-records 1000 --record-size 100 --throughput 100 --producer-props bootstrap.servers=localhost:9092
消费者
kafka-manager web界面管理
docker run -d --name kafka-manager --link zookeeper:zookeeper --link kafka:kafka -p 9000:9000 --restart=always --env ZK_HOSTS=zookeeper:2181 sheepkiller/kafka-manager
参考：
https://kafka.apache.org/
