作用: 通用命令行非 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