/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 votes131 views1 answer
Spigot how to make an inventory
Java
0 vote135 views1 answer
Mvn spring boot ends when closing vm
Java Spring
1 vote136 views1 answer
Unable to find bundled Java version.
Java
0 vote124 views1 answer
Java ordenar numeros ascendente
Java
-1 vote164 views1 answer
Java byte array to blob
Java
0 vote132 views1 answer
Java compareto jdei stackoverflow
Java
2 votes126 views1 answer
How to iterate through an array backwards java
Java
33 votes165 views10 answers
Intellij
Java
0 vote138 views1 answer
Unable to resolve activity for: Intent { act=android.intent.action.MAIN cat=[android.intent.category.LAUNCHER] cmp=com.nicpic.pltestingall/.HiltTestActivity (has extras) } at androidx.test.core.app.InstrumentationActivityInvoker.startActivity
Java
0 vote130 views1 answer
Program to check if the given date is in in the format dd/mm/yyyy java
Java