基础操作

> 创建Topic

./kafka-topics.sh --zookeeper localhost:2181 --create --topic lfwer --partitions 10 --replication-factor 1

- 2.8 以后的新版没有zookper使用以下命令
` ./kafka-topics.sh --bootstrap-server localhost:9092  --create --topic test --partitions 3  --replication-factor 1`

> 查询所有Topic

./kafka-topics.sh --zookeeper localhost:2181 --list
- 2.8 以后的新版没有zookper，将zookper替换成bootstrap-server选项


> 生产和消费消息

./kafka-console-producer.sh --topic lfwer --broker-list 192.168.14.81:9092
./kafka-console-consumer.sh --topic lfwer --bootstrap-server 192.168.14.81:2181

> 查询某个topic的消费组
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list 

> 查看指定group的消费状态

./kafka-consumer-groups.sh --bootstrap-server 192.168.14.81:9092 --describe --group lfwer