/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 vote139 views1 answer
Java create list of 1 element
Java
30 votes183 views6 answers
For each loop in java
Java
1 vote186 views1 answer
Java hash password
Java
0 vote199 views1 answer
Convert date to offsetdatetime in java
Java
7 votes174 views2 answers
How to know java version in cmd
Java
3 votes220 views5 answers
Calc
Java
0 vote225 views2 answers
Java how to create subclass
Java
0 vote185 views2 answers
How to find the largest number in java
Java
0 vote178 views1 answer
Read properties file outside jar java
Java
3 votes253 views3 answers
Java does file exist
Java