基于Kafka集群的动态限速方法、装置以及计算机设备
授权
摘要
本申请公开了一种基于Kafka集群的动态限速方法，该方法包括：获取Kafka集群中目标Kafka节点在当前时间段的多个输入输出指标值；当任一所述输入输出指标值大于第一阈值时，若所述目标Kafka节点的数据读出率小于或等于预设的第二阈值，查找出写入数据量超过预设的第三阈值的主题分区作为第一目标主题分区并调整其写入速度；若所述数据读出率大于所述第二阈值，查找出对所述目标Kafka节点中第二目标主题分区对应的磁盘执行数据读出操作且读出速度大于预设的第四阈值的消费者作为目标消费者并调整其读出速度。本申请还提供一种基于Kafka集群的动态限速装置、计算机设备以及计算机可读存储介质。本申请能够实现对Kafka集群的精确限速，提高了限速执行效率。
基本信息
专利标题 ：
基于Kafka集群的动态限速方法、装置以及计算机设备
专利标题（英）：
暂无
公开（公告）号 ：
CN112367384A
申请号 ：
CN202011190715.X
公开（公告）日 ：
2021-02-12
申请日 ：
2020-10-30
授权号 ：
CN112367384B
授权日 ：
2022-06-03
发明人 ：
张辰安付航郑志升
申请人 ：
上海哔哩哔哩科技有限公司
申请人地址 ：
上海市杨浦区政立路485号国正中心3号楼
代理机构 ：
北京英特普罗知识产权代理有限公司
代理人 ：
邓小玲
优先权 ：
CN202011190715.X
主分类号 ：
H04L29/08
IPC分类号 ：
H04L29/08 G06F9/54
法律状态
2022-06-03 ：
授权
2021-03-05 ：
实质审查的生效
IPC(主分类) : H04L 29/08
申请日 : 20201030
申请日 : 20201030
2021-02-12 ：
公开
注：本法律状态信息仅供参考，即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载
