/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

2 votes325 views1 answer
Printing a treeset java
Java
4 votes363 views3 answers
Exit app android
Java
-1 vote356 views1 answer
Mysql connection details in springboot
Java
15 votes404 views10 answers
Flutter
Java
0 vote336 views1 answer
How can i convert an int to string java
Java
0 vote369 views1 answer
Get intersection of two lists java
Java
1 vote340 views1 answer
How to make jframe visible
Java
8 votes372 views2 answers
Java round to 2 decimal places
Java
0 vote380 views1 answer
Java remote debug
Java
0 vote365 views1 answer
In java write a code that suppose the following input is supplied to the program: 9 Then, the output should be: 12096 (99+999+9999+999)
Java