pulsar-connector-stats

#!/usr/bin/env bash

set -e

NS=$(kubectl config view --minify --output 'jsonpath={..namespace}')
>&2 echo "namespace: ${NS}"

BROKER=$(kubectl get pods | grep broker | head -n1 | cut -d" " -f1)
>&2 echo "broker: ${BROKER}"

TOPICS=$(kubectl exec -ti $BROKER -- ./bin/pulsar-admin topics list $NS/_connectors | xargs -I {} | tr -d '"')
>&2 echo "topics:
$TOPICS"

for topic in $TOPICS
do
>&2 echo "stats for topic: $topic"
  kubectl exec -ti $BROKER -- ./bin/pulsar-admin topics stats $topic
done