pingcap/tiflow

ticdc: improve error message when downstream kafka is unavailable

开放

#11,540 创建于 2024年8月29日

在 GitHub 查看贡献者指南
 (0 条评论) (0 个反应) (1 位负责人)Go (310 个派生)auto 404
affects-7.5good first issueseverity/minortype/enhancement

仓库指标

星标
 (461 个星标)
PR 合并指标
 (PR 指标待抓取)

描述

When downstream kafka is unavailable, kafka sink will try to restart. After several restart, it will report an error like "table sink stuck".
The error message doesn't explain what happened and is useless to help customer to locate the problem, so we need to imporve this error message to explain the cause of the problem.

贡献者指南

研究方向
找到TiCDC Kafka sink中生成“table sink stuck”错误的代码。跟踪重启逻辑，了解何时触发该错误。改进错误消息以包含原因（例如下游Kafka不可用）以及可能的底层错误。查找相关测试并在需要时更新。
技术栈
go
领域
backend
议题类型
缺陷
难度面向新贡献者的预计实现难度，1 表示很小改动，5 表示专家级工作。
2
预计时间有经验贡献者完成调查、实现、测试并准备 pull request 的粗略时间范围。
1-3 小时
活动状态议题当前的可参与程度：新鲜、活跃、陈旧、阻塞或等待维护者输入。
活跃
清晰度议题是否清楚说明期望改动、验收标准和下一步。
清晰
前置要求
Go
新手友好度1-100 的估计分数，表示该议题对首次贡献者的友好程度。
75