/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

0 vote380 views1 answer
Build path specifies execution environment JavaSE-1.8. There are no JREs installed in the workspace that are strictly compatible with this environment.
Java
4 votes395 views2 answers
Java file path linux
Java
2 votes349 views1 answer
Android get list element by index
Java
12 votes348 views3 answers
Public static void main(string args)
Java
1 vote319 views1 answer
Java create list of 1 element
Java
2 votes351 views1 answer
Android how to split string
Java
1 vote376 views1 answer
Textview set drawable right programmatically
Java
0 vote427 views1 answer
Ternary operator in java for null check
Java
0 vote393 views2 answers
Illegal expression
Java
1 vote358 views1 answer
Spigot remove every entity
Java