Flink CDC监听商品表数据 ，然后清理redis 商品缓存?

首先，你需要在 Flink 中配置 CDC 数据源，使其能够连接到你的数据库系统并捕获商品表的变化数据。然后，你可以将捕获的数据流通过 Flink Table API 转换为流表，然后使用表 API 的 sink () 函数将数据流发送到 Redis，这样就可以清空或更新Redis中的商品缓存。在这个过程中，如果遇到Flink CDC作业未能正常消费删除事件的问题，可能由于网络问题或其他错误，Flink CDC没有正确消费对应的删除事件（delete change log event），所以结果表没有受到影响，数据未被删除。因此，检查和调试Flink CDC作业的配置是非常重要的。

你的需求可以通过以下步骤实现：

1. 使用Flink CDC（Change Data Capture）监听商品表的数据变化。Flink CDC可以从数据库的binlog中读取数据变更，并将这些变更实时地传输到Flink流处理引擎。

2. 在Flink中，你可以定义一个处理函数来处理接收到的商品表数据变更。在这个处理函数中，你可以根据需要清理Redis中的商品缓存。

日志搜下 ：from savepoint
redis和mysql没有关系呀，此回答整理自钉群“Flink CDC 社区”