AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
高可用
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积压量
收藏
立即使用
高可用
西西2020
职业：暂无
去主页
Collect
Get Started
高可用
Collect
Get Started
高并发与高可用
Collect
Get Started
WMS高可用部署架构
Collect
Get Started
高可用技术架构图
评论
0
条评论
下一页
Document
