/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 vote187 views1 answer
Original authors: Talmon Marco, Igor Magazinnik Programming languages: Java, C, Python, C , Qt, Objective-C
Java
1 vote140 views1 answer
Java make a null string
Java
0 vote145 views1 answer
Selenium treeview java
Java
0 vote154 views3 answers
How to cut a certion part from a string in java
Java
0 vote154 views1 answer
Check if the given string is a number
Java
0 vote178 views1 answer
Java file get bytes
Java
6 votes159 views4 answers
Sort 2d array based on one column java
Java
0 vote153 views2 answers
Uninstall java 11 linux
Java
0 vote153 views2 answers
How to find the largest number in java
Java
0 vote147 views1 answer
How to avoid outside click of alerdialoge android
Java