`
liudunxu2
  • 浏览: 30649 次
  • 性别: Icon_minigender_1
  • 来自: 青岛
文章分类
社区版块
存档分类
最新评论

metaq的consumer执行机制

 
阅读更多
1.metaq如果不指定executor,则默认是单线程执行的。
2.如果一个consumer订阅了多个topic,也是单线程执行。
3.如果消费抛出异常,会重新加入到blockqueue(根据delayTimeStamp排序的优先队列),并更新延迟时间
4.当重试次数(在postReceiveMessage赋值,判断依据是iterator的offset是否为0)超过配置的最大值(默认为5次),则记录日志,丢弃消息
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics