/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

5 votes167 views3 answers
Java program to remove duplicate words in a string
Java
0 vote186 views1 answer
Mapping over a list of promises in javaascript
Java
2 votes176 views1 answer
Java custom color
Java
0 vote170 views1 answer
Maven Dependency for flyway
Java
0 vote238 views1 answer
Android date time
Java
0 vote166 views1 answer
Goodbye java
Java
1 vote165 views2 answers
Array erstellen java
Java
4 votes168 views1 answer
Thread
Java
1 vote175 views1 answer
String vs stringbuilder
Java
0 vote186 views1 answer
How to print all package in java
Java