[New post] Java code snippet – How to check number of messages in kafka topic?

Subash Chandran posted: "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 ":" '{" New post on Poopcode Java code snippet – How to check number of messages in kafka topic? by Subash Chandran 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)) Read more of this post Subash Chandran | October 27, 2021 at 7:09 am | Tags: check number of messages in kafka topic command, for viewi number of the messages in a kafka topic | Categories: Snippets | URL: https://wp.me/pb9kQA-4bF Comment    See all comments Unsubscribe to no longer receive posts from Poopcode. Change your email settings at Manage Subscriptions. Trouble clicking? Copy and paste this URL into your browser: https://poopcode.com/java-code-snippet-how-to-check-number-of-messages-in-kafka-topic/