/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 vote189 views1 answer
How to decode a ByteArray to Bitman in adroid
Java
4 votes227 views2 answers
Number of lines in file java
Java
0 vote185 views1 answer
Java Classs Decomiler free
Java
1 vote175 views1 answer
Java check if able to parse int
Java
26 votes183 views3 answers
Java random between
Java
4 votes181 views2 answers
Send message to all player java spigot
Java
0 vote235 views1 answer
Kkih
Java
0 vote207 views1 answer
Minecraft inventory share plugin
Java
1 vote142 views1 answer
Import androidx.core.util.ArraySet; ^ symbol: class ArraySet location: package androidx.core.util
Java
0 vote189 views1 answer
Java string contains number
Java