/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

10 votes224 views5 answers
Array average
Java
1 vote206 views1 answer
MCQ java
Java
-3 votes236 views3 answers
Generic classes in java
Java
0 vote312 views1 answer
Spring delete objest from database that are not in your object list
Java Spring
1.2K votes318 views10 answers
Twitch
Java
0 vote234 views1 answer
Java windowbuilder launch on second monitor
Java
0 vote210 views1 answer
Mock ioexception mockito on BufferedReader
Java
0 vote239 views1 answer
Classloader in static method
Java
3 votes293 views1 answer
Jpql spring boot
Java Spring
3 votes205 views1 answer
Java console write
Java