美文网首页
kafka基础

kafka基础

作者: cotecc | 来源:发表于2018-05-10 11:47 被阅读0次

一、常用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

相关文章

网友评论

      本文标题:kafka基础

      本文链接:https://www.haomeiwen.com/subject/badzrftx.html