/Java/How to check number of messages in kafka topic

How to check number of messages in kafka topic

brokers="<broker1:port>"
topic=<topic-name>
sum_1=$(/usr/hdp/current/kafka-broker/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list $brokers --topic $topic --time -1 | grep -e ':[[:digit:]]*:' | awk -F  ":" '{sum += $3} END {print sum}')
sum_2=$(/usr/hdp/current/kafka-broker/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list $brokers --topic $topic --time -2 | grep -e ':[[:digit:]]*:' | awk -F  ":" '{sum += $3} END {print sum}')
echo "Number of records in topic ${topic}: "$((sum_1 - sum_2))

Source: stackoverflow.com

Similar codes

0 vote260 views1 answer
Spring security controlleradvice
Java
1 vote264 views1 answer
Sort array<entry> float android studio
Java
0 vote268 views1 answer
Java android edit text set value
Java
5 votes267 views6 answers
Spring boot tutorial
Java
1 vote301 views1 answer
Renardfute
Java
1 vote325 views2 answers
Java get month
Java
4 votes289 views2 answers
Java how to find the largest number in an arraylist
Java
0 vote273 views1 answer
Spring boot MVC config
Java
0 vote253 views1 answer
Wsl-allow-port
Java
3 votes303 views1 answer
Android Splash Screen
Java