kafka常用系统命令-1

 

1. 查看所有topic

/bin/kafka-topics.sh --zookeeper ip:端口  --list 

2. 查看topic最新偏移量

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ip:端口 --topic 主题 --time -1

　　

3. 修改topic发送数据最大内存

bin/kafka-configs.sh  --entity-type topics --entity-name 主题名字 --alter --add-config max.message.bytes=大小   --zookeeper ip:端口,ip:端口 

4.查看消费组消费到的offset

 bin/kafka-consumer-groups.sh --bootstrap-server  ip:端口,ip:端口 --describe --group 分组id

5.查看所以 group_id

bin/kafka-consumer-groups.sh   --bootstrap-server ip:端口,ip:端口 --list

6.查看主题描述

bin/kafka-configs.sh --describe --entity-type topics --entity-name  主题 --zookeeper ip:端口,ip:端口