/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

3 votes283 views1 answer
Isprime check formula java
Java
2 votes265 views1 answer
Copy array in java 2d
Java
0 vote277 views1 answer
Intergers are appearing as string in Json
Java
0 vote276 views1 answer
Jaava print line
Java
-3 votes242 views3 answers
Java String join
Java
1 vote283 views1 answer
Java class from string
Java
0 vote279 views1 answer
Correct lcd initialize
Java
0 vote279 views1 answer
Enum type spring boot entity
Java
0 vote256 views1 answer
Sprint jpa properties for application.yml
Java
0 vote308 views1 answer
How to write a perfect shuffle method in java
Java