/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

4 votes364 views2 answers
What does the continue keyword do in java
Java
0 vote322 views1 answer
Java fahrenheit to celsius
Java
0 vote340 views1 answer
Android paint drawtext multiline
Java
0 vote359 views1 answer
Java cannot find file path
Java
0 vote352 views1 answer
Get today date in java 8
Java
1 vote387 views2 answers
Java: error: release version 5 not supported maven
Java
0 vote367 views1 answer
Export to csv - Java
Java
0 vote321 views1 answer
RTC_WAKEUP
Java
0 vote330 views1 answer
Main methode java
Java
0 vote331 views2 answers
Java list sort comparator date descending lambda
Java