/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 vote300 views1 answer
Java resultset to object
Java
0 vote361 views1 answer
Java: cannot access javax.naming.Referenceable class file for javax.naming.Referenceable not found
Java
0 vote308 views1 answer
What is return method in java
Java
0 vote287 views1 answer
Java indexof not found
Java
1 vote278 views1 answer
CSV to 2D array javaescript
Java
0 vote288 views1 answer
Using new to create arrays
Java
1 vote307 views2 answers
How to create dynamic string array in java
Java
0 vote301 views4 answers
How to stop extending jpa repository to every class in java
Java
0 vote354 views2 answers
Java map to list or array
Java
0 vote273 views2 answers
Get week number from localdate java
Java