/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 vote302 views1 answer
Java connect mariadb
Java
0 vote287 views2 answers
Ein wort in buchstaben zerlegen java
Java
0 vote292 views1 answer
Java filter array by even numbers
Java
1 vote299 views1 answer
Entryset in java loop
Java
0 vote311 views2 answers
How we can use for loop three times in java
Java
1 vote298 views1 answer
Char to string jva
Java
0 vote283 views1 answer
Convert character arraylist to array
Java
3 votes274 views1 answer
Java get mouse position on screen
Java
6 votes302 views2 answers
Check type of variable java
Java
5 votes290 views1 answer
Exit from jshell
Java