kafkaping is like IP ping, but for Kafka. To be precise, it's producing into a broker's topic, and consuming, measuring the latency between them.
Usage: kafkaping [-g] [-t topic] [-c count] [-i interval_ms] [broker list] -g Increases debugging print verbosity -t TOPIC What Kafka topic to use for producing/consuming messages [kafkaping] -c COUNT Number of messages to send & receive before quitting [unlimited] -i MSECS Time to wait between to pings
# kafkaping -c4 localhost Received from localhost: topic=kafkaping partition=0 offset=385 time=126 ms Received from localhost: topic=kafkaping partition=0 offset=386 time=17 ms Received from localhost: topic=kafkaping partition=0 offset=387 time=12 ms Received from localhost: topic=kafkaping partition=0 offset=388 time=13 ms --- localhost ping statistics --- 4 messages received, time 5222ms rtt min/avg/max = 12/42/126 ms
Build time dependencies
sudo apt install autoconf automake make g++ pkg-config librdkafka-dev
How to build
./autogen.sh ./configure make sudo make install