Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #Usage: topic-count <topic-name>
- BROKERLIST="kafka:9092"
- KAFKA_HOME="/opt/kafka_2.11-2.2.0/"
- TOPIC_NAME=$1
- if [ -z $TOPIC_NAME ]; then echo "Missing TOPIC_NAME(arg1)"; exit 1; fi
- if [ -z $BROKERLIST ]; then echo "Missing BROKERLIST"; exit 1; fi
- if [ -z $KAFKA_HOME ]; then echo "Missing KAFKA_HOME"; exit 1; fi
- MIN_OFFSET=`$KAFKA_HOME/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list $BROKERLIST --topic $TOPIC_NAME --time -2 | awk -F ":" '{sum += $3} END {print sum}'`
- MAX_OFFSET=`$KAFKA_HOME/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list $BROKERLIST --topic $TOPIC_NAME --time -1 | awk -F ":" '{sum += $3} END {print sum}'`
- echo "Count: $(($MAX_OFFSET-$MIN_OFFSET)) MinOffset: $MIN_OFFSET MaxOffset: $MAX_OFFSET"
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement