Installation

Linux

Update system with apt

apt install kafkacat -y

Docker

Install docker

docker run -it --network=host edenhill/kcat:1.7.1 -b YOUR_BROKER -L

Usage

# List broker metadata
kafkacat -L -b localhost:9092
echo '{"col_foo":1}'|kafkacat -b localhost:9092 -t test -P -H foo=bar

Version

kafkacat -V

Appendix