/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 vote163 views1 answer
String to pojo java
Java
0 vote182 views2 answers
Cors spring method or class
Java Spring
5 votes189 views2 answers
Set jframe fullscreen
Java
0 vote136 views1 answer
What is the process of mvvm in android
Java
1 vote148 views1 answer
Complicated average java code
Java
4 votes161 views1 answer
Rates api
Java
0 vote140 views1 answer
Component spring
Java
2 votes138 views2 answers
Android java transparent background
Java
3 votes158 views3 answers
How to print each element of an arraylist on a new line in java
Java
0 vote172 views1 answer
Minecraft inventory share plugin
Java