/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 vote225 views1 answer
Creategoogle maps marker with custom image/bitmap
Java
0 vote175 views1 answer
Nsxt resource relationships in java
Java
0 vote227 views1 answer
How to style Bottom Sheet
Java
1 vote230 views2 answers
Java repository sql find not in list
Java
2 votes194 views1 answer
System.arraycopy
Java
0 vote224 views2 answers
Close GUI in jvava
Java
0 vote194 views1 answer
Naming convention for selenium java automation
Java
0 vote247 views1 answer
Android BottomSheetDialogFragment not opening fully on landscape
Java
1 vote196 views1 answer
Add two numbers bitwise
Java
1 vote219 views1 answer
Access a string from another class java
Java