Advertisement
Guest User

Untitled

a guest
May 21st, 2019
101
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.75 KB | None | 0 0
  1. #Usage: topic-count <topic-name>
  2.  
  3. BROKERLIST="kafka:9092"
  4. KAFKA_HOME="/opt/kafka_2.11-2.2.0/"
  5. TOPIC_NAME=$1
  6.  
  7. if [ -z $TOPIC_NAME ]; then echo "Missing TOPIC_NAME(arg1)"; exit 1; fi
  8. if [ -z $BROKERLIST ]; then echo "Missing BROKERLIST"; exit 1; fi
  9. if [ -z $KAFKA_HOME ]; then echo "Missing KAFKA_HOME"; exit 1; fi
  10.  
  11. 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}'`
  12. 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}'`
  13.  
  14. echo "Count: $(($MAX_OFFSET-$MIN_OFFSET)) MinOffset: $MIN_OFFSET MaxOffset: $MAX_OFFSET"
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement