/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 vote247 views1 answer
How to get logarithm in java
Java
0 vote260 views1 answer
Mostrar todos los elementos de un arraylist java
Java
0 vote241 views1 answer
Java bild skalieren bufferedimage
Java
0 vote285 views1 answer
Android BottomSheetDialogFragment not opening fully on landscape
Java
0 vote240 views1 answer
Java trim unicode \u200b
Java
0 vote271 views1 answer
Intellij set target bytecode version
Java
30 votes250 views6 answers
Reverse string in java
Java
9 votes244 views2 answers
Input char java
Java
0 vote240 views1 answer
Ubuntu java development kit
Java
4 votes232 views4 answers
Sum of list java
Java