一窜管、常用shell命令
1. 列出所有topic
sh kafka-topics.sh --list --zookeeper localhost:2181
2. 查看kafka版本
# 在kafka安裝目錄執(zhí)行
find ./libs/ -name 'kafka_*.jar.asc' |head -n1 | cut -d'/' -f3
kafka_2.10-0.10.1.2.6.4.0-91-sources.jar.asc
注：2.10是scala版本列赎，0.10.1是kafka版本
3. 查看offset
#查看某個(gè)group 連接到的broker topic的分區(qū)及對(duì)應(yīng)offset信息
bin/kafka-consumer-groups.sh --bootstrap-server ip:port --group group_id --describe
image.png
