安裝kafka：
kafka的功能需要依賴zookeeper绿映，所以需要先在docker官網(wǎng)上下載zookeeper和kafka的鏡像包（如果linux環(huán)境聯(lián)網(wǎng)蓬戚，可直接拉取鏡像：docker pull zookeeper:版本號? ?docker pull kafka:版本號）
啟動zookeeper容器：
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
啟動kafka容器：
docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 --env KAFKA_ADVERTISED_HOST_NAME=172.16.1.80 --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime wurstmeister/kafka:latest
kafka常用操作命令：
首先進(jìn)入kafka容器內(nèi)部： docker exec -it kafka? /bin/bash
進(jìn)入到操作目錄下：cd opt/kafka/
查看主題列表：
bin/kafka-topics.sh --list --zookeeper 172.16.1.80:2181
創(chuàng)建主題(命名為test)：
bin/kafka-topics.sh --create --zookeeper 172.16.1.80:2181 --replication-factor 1 --partitions 1 --topic test
刪除主題：
bin/kafka-topics.sh --delete --topic test --zookeeper 172.16.1.80:2181
創(chuàng)建生產(chǎn)者：
bin/kafka-console-producer.sh --broker-list 172.16.1.80:9092 --topic test
創(chuàng)建消費(fèi)者：
bin/kafka-console-consumer.sh --bootstrap-server 172.16.1.80:9092 --topic test --from-beginning
查詢集群描述:
bin/kafka-topics.sh--describe --zookeeper?
消費(fèi)者列表查詢:
bin/kafka-topics.sh--zookeeper 172.16.1.80:2181 --list
高級點(diǎn)的用法:
bin/kafka-simple-consumer-shell.sh--brist localhost:9092--topic test --partition0--offset1234--max-messages10
平衡leader:
bin/kafka-preferred-replica-election.sh--zookeeper zk_host:port/chroot
kafka自帶壓測命令:
bin/kafka-producer-perf-test.sh--topic test --num-records100--record-size1--throughput100--producer-props bootstrap.servers=localhost:9092
注：命令中的主機(jī)ip 172.16.1.80 需要更換成自己的主機(jī)ip
