kafka調試工具kafkacat的使用

1、 安裝

kafkacat 是基於kafka C語言的librdkafka庫的 kafka客戶端，不依賴java，小巧輕便，支持主流系統。
在高版本的debain、Ubuntu下能夠直接apt-get install kafkacat，maxos下能夠用brew install kafkacat
也能夠本身編譯，也是很是簡單(須要先安裝好curl和 cmake)
apt-get install cmake
git  clone https://github.com/edenhill/kafkacat
cd kafkacat && ./bootstrap.sh

2、用法

一、查看kafka信息(kafka_broker表示kafka服務器的地址，下同）

kafkacat -L -b kafka_broker

二、消費者 

a、訂閱全部消息
kafkacat -C -b kafkabroker -t topicname
b、讀取制指定個數的消息（能夠查看kafka裏是否有消息）
kafkacat -C -b kafkabroker -t topicname -p 0 -o -個數 -e  

三、生產者

a、直接發送  按下enter鍵後，等待鏈接成功就能夠發送消息了,ctrl+d 退出發送消息
kafkacat -b kafkabroker -t topic  -P
b、經過管道發送
cat msg.txt |  kafkacat -b kafkabroker -t topic  -P

四、轉發消息 

能夠經過管道把接收到的消息轉發到生產者
kafkacat -C -b kafkabroker1 -t topic1 -e | kafkacat -P -b kafkabroker2 -t topic2

五、配置

kafkacat 使用的是librdkafka的配置，使用時能夠經過 '-F'指定配置文件。
好比 SASL_PLAINTEXT登陸，新建一個配置文件, 如 kafka.conf

security.protocol=SASL_PLAINTEXT
sasl.mechanisms=PLAIN
sasl.username=username
sasl.password=pwd

kafkacat -L -b kafka_broker -F kafka.conf