kafka异常消息处理
2022-10-21 16:26:29 1 举报kafka异常消息处理流程
作者其他创作
大纲/内容
是
是否异常
结束
判断是否需要消息预警等
logstash发送消息
否
logstash
消费异常消息
是否需要自动重试
业务消费者
本地重试/线程池
判断异常是否为可恢复异常
是否超过最大重试次数
kafka异常消息处理
收集异常信息
消费重试消息
重试消息队列消费者
发送重试消息
服务端
消费消息
消息预警
是否需要本地重试
通过反射调用消费者的消费方法
收藏
0 条评论
下一页
