【发布时间】：2019-12-28 10:42:49
【问题描述】：
我正在运行一个带有错误转换的接收器，它在接收器 mysql 表中产生错误的数据，但是当我使用 PUT REST API 更正接收器配置并运行它时，它成功运行但不更新接收器表中的现有数据？
【问题讨论】：
标签： mysql apache-kafka apache-kafka-connect debezium
【发布时间】：2019-12-28 10:42:49
【问题描述】：
如果您的数据没有被任何人使用，那么您可以使用以下步骤：
- 停止源和接收器连接器，
- 从 kafka 主题中清除数据，
- 清理特定主题的接收器数据库数据，
- 从 kafka 中删除（或重命名）表历史主题
- 更改源连接器名称
- 启动两个连接器。
【讨论】：
-
是的，你是对的，但我已经使用了来自 source 和 sink 的 kafka 数据和 db 数据。