/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 vote148 views1 answer
@SpringBootApplication
Java
0 vote197 views1 answer
Declaration of double array in java
Java
0 vote156 views1 answer
Stream reduce stringbuilder
Java
0 vote142 views1 answer
Ursina vsync
Java
-1 vote155 views1 answer
A ^ b java
Java
1 vote137 views1 answer
Slice a list java
Java
2 votes168 views2 answers
Android studio print console
Java
0 vote154 views1 answer
Netbeans how to get string from jcombobox
Java
0 vote172 views2 answers
How to add background color in jframe
Java
1 vote151 views1 answer
Java get fps from thread
Java