/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 vote146 views1 answer
Play mp3 android java
Java
2 votes133 views1 answer
Set of char in java
Java
0 vote135 views1 answer
Java JButton onClick
Java
45 votes155 views5 answers
Java iterate through hashmap
Java
0 vote149 views1 answer
Java string get ith char
Java
0 vote143 views1 answer
Add seconds to today date and time java
Java
0 vote144 views1 answer
Ass
Java
2 votes123 views1 answer
Rider find and replace
Java
22 votes137 views2 answers
Java close application
Java
0 vote137 views1 answer
Reading txt file javafx
Java