Kafka驗證

Last updated on 

安裝kcat

kcat github

生產者

echo '{"foo": "test"}' | kcat -X security.protocol=SASL_PLAINTEXT -X sasl.mechanism=PLAIN -X sasl.username=<kafka 生產者帳號> -X sasl.password=<kafka 生產者密碼> -b <kafka domain>:port -t <topic>

驗證

kcat -X security.protocol=SASL_PLAINTEXT -X sasl.mechanism=PLAIN -X sasl.username=<kafka 消費者帳號> -X sasl.password=<kafka 消費者密碼> -b <kafka domain>:port -t <topic>