/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 vote136 views1 answer
Jbutton remove selection border
Java
0 vote127 views1 answer
Resultset previous
Java
0 vote134 views1 answer
Android search in webview
Java
0 vote128 views1 answer
Pop back stack fragment android
Java
3 votes136 views1 answer
Space in java
Java
59 votes136 views3 answers
How to use math.round
Java
0 vote127 views1 answer
Delete Specials Caractères from a String in java
Java
4 votes128 views3 answers
Regex for letters and number
Java
0 vote156 views1 answer
Ldap java connection
Java
87 votes216 views6 answers
Hello world in java
Java