/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

3 votes128 views2 answers
Arraylist methods in java
Java
-3 votes119 views2 answers
Multiplication table for number Java
Java
0 vote122 views1 answer
Java break 2 for loops
Java
2 votes129 views2 answers
Split each character in a string (java)
Java
2 votes121 views3 answers
Java thread
Java
1 vote132 views1 answer
Unable to find bundled Java version.
Java
0 vote129 views1 answer
Public static void trong java là gì
Java
2 votes129 views2 answers
Count number of words in a String
Java
0 vote129 views1 answer
Cpp in
Java
-1 vote124 views2 answers
Android dismiss keyboard
Java