/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

9 votes161 views3 answers
Java loop through string
Java
2 votes252 views2 answers
Java string join arraylist
Java
0 vote159 views2 answers
&& java
Java
0 vote214 views1 answer
How to multiply a number by itself using for loop in java
Java
0 vote166 views1 answer
Android gridview item click effect ripple
Java
0 vote172 views1 answer
Textfield border radiuis in javafx
Java
0 vote174 views1 answer
Action media scanner scan file android 30 deprecated
Java
0 vote166 views1 answer
Java nested array hashcode
Java
1 vote220 views1 answer
Renardfute
Java
3 votes184 views3 answers
Java ternary
Java