/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 vote208 views1 answer
Java unused import statement
Java
0 vote163 views1 answer
Java split not working
Java
0 vote235 views1 answer
Find duplicate value in array java
Java
3 votes203 views1 answer
How to convert primitive int to Integer in java
Java
0 vote243 views1 answer
How do I make my Android app scrollable?
Java
5 votes215 views1 answer
RecyclerView OnItemClickListener
Java
0 vote230 views1 answer
Hcf
Java
0 vote265 views1 answer
React native appearance.addchangelistener android
Java
0 vote242 views2 answers
Java find all of letter in string
Java
0 vote246 views1 answer
Org.apache.hadoop.mapred.JobClient.runJob(JobClient.java:876)
Java