/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 vote160 views1 answer
Spring data jpa inheritance repository
Java Spring
1 vote121 views3 answers
Statusbar text color android
Java
1 vote141 views2 answers
Java check two dates same day
Java
2 votes116 views1 answer
For with two values java
Java
10 votes118 views5 answers
Array average
Java
0 vote119 views1 answer
Java mockito print called methods
Java
0 vote126 views1 answer
What is collection fromework
Java
1 vote122 views5 answers
Change status bar color android programmatically
Java
1 vote118 views2 answers
Set icon to fab programmatically in android studio
Java
0 vote125 views1 answer
Assert Two Lists for Equality Ignoring Order in Java
Java