/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 votes262 views3 answers
Sum of all numbers in array java
Java
-1 vote281 views1 answer
Spring jpa query with union all
Java Spring
0 vote249 views1 answer
Java scanner class time
Java
0 vote279 views1 answer
What singleton java spring
Java Spring
1 vote269 views1 answer
Calendar java add 1 day
Java
0 vote275 views1 answer
Read array of characters from space separated values in java
Java
0 vote238 views1 answer
Console java echo hello you
Java
1 vote240 views2 answers
Java stream sort
Java
-2 votes245 views1 answer
Enhanced for-loop,
Java
0 vote245 views3 answers
Bundletool aab to apk
Java