/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 vote196 views1 answer
Nikita kaksharov
Java
0 vote164 views1 answer
Java initialize list with default value
Java
1 vote242 views2 answers
How to do annotation configuration in spring
Java Spring
0 vote226 views1 answer
How to find the logged-in user in Spring Boot?
Java Spring
0 vote192 views1 answer
Android studio define array
Java
0 vote278 views1 answer
Java socket get ip address of client
Java
0 vote198 views1 answer
How to write 1,2,3,4.... in java
Java
0 vote269 views1 answer
Lelen suratlari ramkasidagi oltinlar
Java
0 vote194 views1 answer
Spring data jpa inheritance repository
Java
1 vote198 views1 answer
How to check if location is enabled android
Java