Nagios plugin to check Apache Kafka for unavailable partitions

check_kafka_unavailparts.sh

#!/bin/bash
#
# Nagios plugin to check Apache Kafka for unavailable partitions
# Zookeeper comma separated addresses are required as a 1st parameter
#
# https://gist.github.com/jazzl0ver
#

ZK=$1

count=$(/bin/docker run --rm --entrypoint /bin/bash -e KAFKA_HEAP_OPTS="-Xmx128M" jazzl0ver/firecamp-kafka:2.3 /kafka/bin/kafka-topics.sh --zookeeper "$ZK" --describe --unavailable-partitions | wc -l)

if [ $count -eq 0 ]; then
    echo "OK: all partitions are available | count=$count"
    exit 0
else
    echo "CRITICAL: $count unavailable partitions found | count=$count"
    exit 2
fi