Kafka error topic事件重驱动回retry topic的实现模式与工具问询

• 批处理全量重放模式：实现一个可手动/定时触发的轻量消费程序，拉取error topic全量消息，校验消息完整性后直接批量写入retry topic，所有消息生产成功后再统一提交error topic的消费offset，避免消息丢失。需要跳过指定消息的场景下，可以在程序里配置过滤规则，比如按消息头的错误类型、消息key、生成时间范围匹配待跳过的消息，这类消息直接提交offset即可，不会进入retry topic。
• 按需筛选重放模式：给error topic的消费服务增加控制逻辑，接收重放指令时按指令指定的范围（offset区间、key列表、内容匹配规则等）拉取消息，只有匹配重放条件的消息才会转发到retry topic，其余消息自动跳过。适合重放规则灵活多变的业务场景。
• 状态校验重放模式：转发消息前先查询对应业务的当前状态，比如因下游服务宕机进入error topic的订单消息，重放前先查订单当前是否已经处理完成，已完成的直接跳过，仍待处理的再转发到retry topic，避免重复处理产生业务脏数据。

• AKHQ（原Kafka HQ）：开源Kafka管控工具，内置死信队列管理能力，支持可视化浏览error topic的全量消息，支持按offset、时间、key、消息内容筛选目标消息，可一键将选中消息转发到指定retry topic，也可手动勾选无需处理的消息直接提交offset实现跳过，完全匹配全量追加、选择性跳过的需求。
• Confluent Control Center：Confluent Kafka生态自带的管控组件，原生支持死信队列消息的浏览、筛选、重放操作，可自定义过滤规则匹配待重放消息，直接批量转发到目标topic，适合已经在使用Confluent技术栈的团队。
• Offset Explorer（原Kafka Tool）：桌面端Kafka管理工具，支持浏览所有topic的消息内容，可按多种维度过滤消息，选中待重放的消息后可直接批量生产到retry topic，也可手动提交指定offset实现跳过无需处理的消息，无需部署服务，本地安装即可使用。
• Kafdrop：轻量级开源Kafka可视化工具，基础功能支持消息浏览、筛选，扩展少量插件即可实现选中消息转发到指定topic的能力，资源占用极低，适合小团队使用。

内容的提问来源于stack exchange，提问作者n00b