是
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,处理下一条消息