/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

1 vote118 views1 answer
Why bufferedreader is faster than scanner
Java
1 vote157 views1 answer
Floatingactionbutton image color
Java
5 votes111 views2 answers
Getcolor deprecated
Java
10 votes218 views3 answers
H2 database spring boot
Java Spring
-1 vote128 views1 answer
Separate string by comma java
Java
10 votes125 views4 answers
Java capitalize first letter of each word
Java
10 votes119 views2 answers
Java substring one parameter
Java
0 vote126 views1 answer
Media style dependency androidx
Java
0 vote130 views1 answer
Java cos'è jvm
Java
0 vote114 views1 answer
How to find last digit in number by regex in java
Java