kafka 相关命令使用_kafka-run-class.sh

//查看主题列表
./kafka-topics.sh --zookeeper 192.168.229.111:2181/kafka \
--list
 
//查看单个主题
./kafka-topics.sh --zookeeper 192.168.229.111:2181/kafka \
--describe \
--topic dsg_test
 
//查看单个主题的消息数量
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.229.111:9092 \
-topic dsg_test --time -1
 
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.229.111:9092 \
-topic dsg_test --time -2
 
–time-1 表示要获取指定topic所有分区当前的最大位移，–time-2 表示获取当前最早位移。
两个命令的输出结果相减便可得到所有分区当前的消息总数。
分区当前的消息总数 = [–time-1] - [–time-2]
 
//消费所有的message
./kafka-console-consumer.sh --bootstrap-server 192.168.229.111:9092 \
--topic dsg_test \
--from-beginning
 
//消费指定offset之后的message
./kafka-console-consumer.sh --bootstrap-server 192.168.229.111:9092 \
--topic dsg_test \
--partition 0 \
--offset 26204851
 
//消费指定offset区间的message
./kafka-console-consumer.sh --bootstrap-server 192.168.229.111:9092 \
--topic dsg_test \
--partition 0 \
--max-messages 1 \
--offset 26204851