Kafka模块化消费流程
2022-02-07 11:33:47 0 举报一套通用的kafka消费流程图
作者其他创作
大纲/内容
是
consumercommit
consumer2 init
捕捉到异常，判断是否强一致性业务
records1
thread(n) poll
records2
否
processer(1)
records
processer(2)
consumer(n) init
result中hasFailures=true且配置了FallBackProcesser
go on
consumer1 init
thread(1) poll
应用启动
终止消费告警通知人工干预
thread(2) poll
processer(n)
fallback processer
result中hasFailures=trueresultMap中该record isSuccess置为false，处理下一条消息
收藏
收藏
0 条评论
下一页
