合 Kafka命令行工具 kcat或kafkacat
简介
kcat, 又称为 kafkacat,是一款非 JVM 的 Kafka 消息生产和消费的命令行工具,适用于 Kafka 0.8 及以上版本。
github地址:https://github.com/edenhill/kcat
生产者模式:kcat 从标准输入读取数据,-D 指定分割符,把数据发送到Kafka 集群,-b 指定集群地址, -t 指定topic名称, -p 指定分区
消费者模式:kcat 从指定的 topic 和 partition 消费数据,并打印到标准输出。
kcat 还支持打印 Kafka 集群的状态,topics,pairtions 信息。
kafkacat has been renamed to kcat to adhere to the Apache Software Foundation's (ASF) trademark policies.
kafkacat 是基于kafka C语言的librdkafka库的 kafka客户端,不依赖java,小巧轻便,支持主流系统。
在高版本的debain、Ubuntu下可以直接apt-get install kafkacat,maxos下可以用brew install kafkacat
也可以自己编译安装。