Skip to content

Instantly share code, notes, and snippets.

@nyrahul

nyrahul/pulsar-admin.sh

Last active April 21, 2024 17:56
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save nyrahul/cec6c17bcb8f03f219e8c9ddb655ee68 to your computer and use it in GitHub Desktop.
Save nyrahul/cec6c17bcb8f03f219e8c9ddb655ee68 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
pulsar-admin.sh
bin/pulsar-admin tenants list
bin/pulsar-admin namespaces list "accuknox"
bin/pulsar-admin topics list "accuknox/cluster"
bin/pulsar-admin topics list "accuknox/datapipeline"
bin/pulsar-admin topics stats "persistent://accuknox/datapipeline/kubearmoralerts" | less
bin/pulsar-admin topics examine-messages --initialPosition latest --messagePosition 1 "persistent://accuknox/datapipeline/kubearmoralerts"
bin/pulsar-admin topics clear-backlog -s "accuknox-data-offloader" "persistent://accuknox/datapipeline/kubearmoralerts"
for persistent in $(bin/pulsar-admin topics list accuknox/discovery); do
for sub in $(bin/pulsar-admin topics subscriptions $persistent); do
echo bin/pulsar-admin topics clear-backlog -s "$sub" "$persistent" >> /tmp/commands.sh;
done
done
bash /tmp/commands.sh
bin/pulsar-admin topics stats "persistent://accuknox/discovery/summary-v2" | less
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment