kafka基础

一、常用shell命令

1. 列出所有topic

sh kafka-topics.sh --list --zookeeper localhost:2181

2. 查看kafka版本

# 在kafka安装目录执行
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

#查看某个group 连接到的broker topic的分区及对应offset信息
bin/kafka-consumer-groups.sh --bootstrap-server ip:port --group group_id --describe

image.png