puslar 空间清理操作
pulsar 找出最大的topic 分区
点击查看代码
#!/bin/bash
dir=/tmp/pulsar
CmdDir=/data/apache-pulsar-2.6.2/bin/
${CmdDir}pulsar-admin tenants list > ${dir}/tenants
> ${dir}/namespaces
cat ${dir}/tenants | while read line
do
${CmdDir}pulsar-admin namespaces list $line >> ${dir}/namespaces
done
function GetTopics
{
> ${dir}/topics
cat ${dir}/namespaces | while read line
do
${CmdDir}pulsar-admin topics list $line >> ${dir}/topics
done
}
> ${dir}/size
cat ${dir}/topics | while read line
do
size=`${CmdDir}pulsar-admin topics stats $line |grep storageSize | awk -F '[, ]+' '{print $4}'`
echo $line ' ' $size >> ${dir}/size
done
清理逻辑
多看官方文档
设置副本数
改变ttl
设置retention size
修改backlog 清理策略
最暴力的方式直接 清理./pulsar-admin namespaces clear-backlog "b/ag"