/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

46 votes161 views3 answers
Print an array java
Java
1 vote118 views2 answers
Java list average
Java
0 vote252 views1 answer
Round bg android
Java
25 votes185 views2 answers
Java iterate over list
Java
0 vote181 views1 answer
Print a letter in java
Java
0 vote185 views1 answer
Void setup
Java
0 vote148 views1 answer
How to create a new imageview in android java
Java
1 vote195 views1 answer
Spring xml file configuration
Java Spring
0 vote195 views1 answer
Java extract zip
Java
6 votes158 views1 answer
Save map to file java
Java