/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

7 votes299 views2 answers
Skip test case command in maven
Java
0 vote308 views1 answer
Javac celar
Java
0 vote329 views2 answers
How apache shiro remember me works
Java
1 vote383 views2 answers
How to do annotation configuration in spring
Java Spring
1 vote310 views1 answer
Menghitung luas lingkaran
Java
0 vote312 views1 answer
Single responsibility
Java
4 votes304 views2 answers
Java current time millis
Java
0 vote314 views2 answers
Round to the next multiple of 5
Java
0 vote310 views1 answer
How to search for charecters in java
Java
8 votes355 views1 answer
Import java math
Java