/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 vote307 views1 answer
Java restart while loop
Java
6 votes306 views3 answers
Android java format date time
Java
0 vote307 views1 answer
Configuration reader java
Java
0 vote310 views1 answer
Redex 2 solution matcher
Java
0 vote331 views1 answer
How to create an indefilite loop in java
Java
0 vote300 views1 answer
How to create a boolean list in java
Java
4 votes303 views5 answers
What are variables in java
Java
-2 votes295 views1 answer
Literals in java
Java
1 vote312 views1 answer
Java time type
Java
0 vote300 views2 answers
Mountain array leetcode
Java