kcat的使用

yum install cmake cyrus-sasl cyrus-sasl-devel curl-devel

cd /root/
git clone https://github.com/edenhill/kcat
cd kcat 
./bootstrap.sh  如果没报错的话，即可在当前目录下生成kcat 二进制文件
mv kcat /usr/local/bin/

$ kcat --help
-C consumer模式
-P producer模式
-G xxx 指定group-id
-L 列出kafka的元数据情况（broker情况、topic情况、partition情况）
-Q 查询模式

-t xx topic名
-p xx partition名
-b xx broker节点host:port
-c xx 消息条数
-e 运行后自动退出
-o xx 指定offset
-q 静默
-T 输出msg到控制台
-J  json格式输出

消费10条记录后推出进程
$ kcat -b localhost:9092 -C -t binlog -o -10 -e

json格式列车kafka元数据情况
$ kcat -b localhost:9092 -L -J | jq .

消费topic中指定时间段的msg 【注意这里时间戳是java的，比python的时间戳最后多3位】
$ $ kcat -b localhost:9092 -C -t binlog -o s@1690917944000 -o e@1690987944000