/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 vote317 views2 answers
Camel java
Java
9 votes489 views2 answers
Change the default port in spring boot codegrepper
Java Spring
0 vote305 views1 answer
Java stream code to ignore null
Java
2 votes316 views2 answers
Install java with brew
Java
0 vote298 views1 answer
Stack push java
Java
0 vote320 views1 answer
Jdialog middle of screen
Java
0 vote321 views1 answer
How to read space separated characters in java
Java
0 vote307 views1 answer
Convert date to offsetdatetime in java
Java
5 votes322 views2 answers
Binary to Decimal Conversion in java
Java
0 vote336 views1 answer
Menuitemcompat getactionview is deprecated in android
Java