kafka 常用命令

1.查看kafka所在目录,查看znode目录

ps -ef|grep kafka
cd /app/kafka/kafka_2.11-1.0.0/bin/
cd ../config
vi server.properties
查看kafka 在zookeeper 上面的znode节点位置，这里注意可能zk后面是目录结构

2.创建topic：1分区 1备份

./kafka-topics.sh --create --zookeeper xx.xx.xx.xx:2181/kafka --replication-factor 1 --partitions 1 --topic IN_OUT_TEST

3.命令行从头消费topic

过时：
./kafka-console-consumer.sh --zookeeper xx.xx.xx.xx:2181/kafka --from-beginning --topic IN_OUT_TEST
现在：
./kafka-console-consumer.sh --bootstrap-server xx.xx.xx.xx:9092 --from-beginning --topic IN_OUT_TEST

4.展示所有topic列表

./kafka-topics.sh --list --zookeeper xx.xx.xx.xx:2181/kafka

5.查看topic组下面，topic的消费情况

./kafka-consumer-groups.sh --describe --bootstrap-server xx.xx.xx.xx:9092 --group test_group
| TOPIC     |  PARTITION | CURRENT-OFFSET | LOG-END-OFFSET |     LAG     | CONSUMER-ID |  HOST  | CLIENT-ID |
| ----------| ---------- | -------------- | -------------- | ----------- | ----------- | ------ | --------- | 
  topic名字      分区id     当前已消费的条数       总条数         未消费的条数       消费id      主机ip     客户端id 

6.查看topic：偏移量、主节点、副本

./kafka-topics.sh --describe --zookeeper xx.xx.xx.xx:2181/kafka --topic IN_OUT_TEST

7.删除没用的topic

./kafka-topics.sh --delete --zookeeper xx.xx.xx.xx:2181/kafka --topic IN_OUT_TEST

8.查看所有用户组

./kafka-consumer-groups.sh --bootstrap-server xx.xx.xx.xx:9092 --list