高可用
2021-11-05 14:15:29 2 举报11
作者其他创作
大纲/内容
等待下次执行
for循环查看每个topic积压是否积压超过1W
继续下一次for循环
通过redis查询：写入的topic所有parition积压量(大于1W算积压)
超过了
写入kfk
没有超过
修改offset等流程
有
补全topic里面的partion积压量
写入:随机partion时，排除上面的partion
注：以上步骤用redis缓存kfk积压结果，来代替直接查询kafka.
parition是否有积压
没有
该步骤可以全局static+10秒定时查询来缓存结果
写入:正常流程写入kfk
主流程for循环里面
去查kafka（所有topic积压情况）
返回
查询redis缓存结果，last_time是否超过20秒
查询指定的topic，拿到里面所有parition积压量
0 条评论
下一页
