//查看所有的topic
./kafka-topics.sh --zookeeper localhost:2181 --list
//创建一个demo的topic
./kafka-topics.sh --zookeeper localhost:2181 --create --topic demo --partitions 1 --replication-factor 1
//删除topic ,注意server.properties中delete.topic.enable=true auto.create.topics.enable=false
./kafka-topics.sh --zookeeper localhost:2181 --delete --topic demo
//在控制台中启动生产者
bin/kafka-console-producer.sh --broker-list 192.168.3.8:9092 --topic demo --producer.config config/producer.properties
//在控制台中启动消费者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.3.8:9092 --topic demo --from-beginning --consumer.config config/consumer.properties
注意：加上权限后：
producer.properties/consumer.properties中需要加入security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN,并且注意bootstrap.servers的配置，如果一直配置的是ip，则此处也要填上ip地址，否则执行命令会报错
# 无权限版本查询(ConsumerOffsetChecker)
./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper 192.168.100.85:2181 --group test --topic hello-sean
# 无权限版本查询(GetOffsetShell)
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.100.87:9093 --topic hello-sean --time -1
# 含权限版本查询
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.87:9093,192.168.100.88:9093,192.168.100.89:9093 --command-config ../config/consumer.properties --list
# 查询单个consumer group
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.87:9093 --command-config ../config/consumer.properties --describe --group 'console-consumer-93774'
# 使用脚本新生产一个consumer group(为了方便查询)
./kafka-console-consumer.sh --bootstrap-server 192.168.100.87:9093,192.168.100.88:9093,192.168.100.89:9093 --topic hello-sean --consumer.config ../config/consumer.properties --new-consumer
本机zookeeper: root用户装的，安装在路径：/opt/zookeeper中
启动脚本：./zkServer.sh start
./zkServer.sh start-foreground 错误显示在前台中