/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

8 votes216 views1 answer
Error could not create the java virtual machine ubuntu 20.04
Java
0 vote226 views1 answer
Java map sorted by key
Java
0 vote273 views1 answer
W/System.err: java.io.IOException: Cleartext HTTP traffic to not permitted
Java
183 votes365 views6 answers
Last element of an array
Java
0 vote220 views1 answer
Call method of another class without creating instance in java android
Java
1 vote234 views1 answer
Java.io.IOException: Can't read fonts
Java
0 vote247 views1 answer
Get the last day of a month in Java
Java
3 votes243 views1 answer
Javafx scrollpane
Java
0 vote268 views5 answers
Static block in java
Java
4 votes219 views5 answers
Java main method
Java