/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 votes202 views1 answer
Java check if directory exists
Java
0 vote174 views1 answer
Hide elements android
Java
0 vote153 views0 answer
Java
0 vote207 views1 answer
Sealed class java codegrepper
Java
0 vote198 views1 answer
Android setTextColor not working
Java
0 vote190 views1 answer
One line hashmap java
Java
0 vote210 views1 answer
1 2 1 3 2 1 4 3 2 1 3 2 1 2 1 1 java
Java
0 vote199 views2 answers
Java secretkey
Java
0 vote194 views1 answer
@Async how it works @EnableAsync
Java
1 vote199 views1 answer
Java integer to binary string with leading zeros
Java