/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 vote114 views1 answer
Advantages of iterator in java
Java
4 votes114 views5 answers
What are variables in java
Java
3 votes107 views2 answers
Java oop
Java
-1 vote126 views1 answer
Why is java so verbose
Java
0 vote137 views1 answer
Spring converter in initbinder
Java Spring
0 vote124 views1 answer
Javafx stage always on top
Java
0 vote107 views1 answer
If en une seul ligne java
Java
0 vote122 views1 answer
Convert jwt claim to string java
Java
0 vote109 views1 answer
Java check if divisible
Java
2 votes106 views1 answer
Java String[] to List
Java