kafkatcat是kafka的一个客户端,可以在命令行下直接模拟kafka的生产者和消费者,也可以获取kafka的meta信息,是使用kafka进行项目开发不可少的工具。
$ apt-get install kafkacat
2.编译安装
依赖
sudo apt-get install librdkafka-dev libyajl-dev
./configure <usual-configure-options>
make
sudo make install
3.docker方式运行
docker run -it --network=host edenhill/kafkacat:1.5.0 -b YOUR_BROKER -L
$ kafkacat -L -b mybroker
kafkacat -P -b 172.10.0.1:9092 -t test -p 0 a.txt
3.消费者
kafkacat -C -b 172.10.0.1:9092 -t test