kcat的使用

2023-08-02 22:25:13 浏览数 (1)

作用: 通用命令行非 JVM Apache Kafka 生产者和消费者

官方地址 https://github.com/edenhill/kcat

编译环境: centos7.9

安装相关依赖包

代码语言:shell复制
yum install cmake cyrus-sasl cyrus-sasl-devel curl-devel

编译安装

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

参数:

代码语言:shell复制
$ 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格式输出

例子:

代码语言:shell复制
消费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

0 人点赞