广播模式消费还是集群模式消费,远程去拉取
启动consumerService\通信
启动线程池的延时任务,清理过时的延时任务
每隔30s检测broker是否还存活
消费成功的偏移量同步到broker
新开一个线程,长轮询,循环阻塞拉取消息
真正pull,需要负载均衡放到下图的pullRequestQueue
有消息就从pullRequestQueue获取,没有就阻塞在这里
相关文章：
相似解决方案
热门标签
广播模式消费还是集群模式消费,远程去拉取
启动consumerService\通信
启动线程池的延时任务,清理过时的延时任务
每隔30s检测broker是否还存活
消费成功的偏移量同步到broker
新开一个线程,长轮询,循环阻塞拉取消息
真正pull,需要负载均衡放到下图的pullRequestQueue
有消息就从pullRequestQueue获取,没有就阻塞在这里
相关文章：