问题一：有没有权威的flink cdc测试方案？
有没有权威的flink cdc测试方案？
参考答案：
Flink CDC是一个用于捕获和处理数据库变更的框架，它提供了一种在分布式环境中实现数据同步的方法。为了确保Flink CDC的正确性和可靠性，可以采用以下测试方案：
- 单元测试：对Flink CDC的核心组件进行单元测试，包括连接器、序列化器、反序列化器等。确保每个组件都能正确地处理不同类型的数据格式和变化事件。
- 集成测试：将Flink CDC与其他系统（如Kafka、MySQL等）集成在一起，模拟实际的数据流场景。测试Flink CDC是否能正确地捕获和处理来自其他系统的变更事件，并将它们转换为适当的数据格式。
- 性能测试：评估Flink CDC的性能表现，包括处理速度、资源消耗等方面。可以通过模拟大量数据的变化事件，并观察Flink CDC的处理时间和资源使用情况来评估其性能。
- 容错性测试：模拟故障情况，例如网络中断、数据库宕机等，以确保Flink CDC能够正确处理这些异常情况，并保持数据的一致性。
- 安全性测试：验证Flink CDC的安全性，包括数据加密、身份验证等方面。确保只有授权的用户才能访问和修改数据。
- 兼容性测试：测试Flink CDC与不同版本的数据库和连接器之间的兼容性。确保在不同环境下，Flink CDC能够正常工作。
- 稳定性测试：长时间运行Flink CDC，观察其稳定性和可靠性。确保在高负载情况下，Flink CDC能够稳定地捕获和处理数据变更。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/584649
问题二：Flink CDC全库订阅binlog你们怎么配置的，我们这好像有漏数据的情况？
Flink CDC全库订阅binlog你们怎么配置的，我们这好像有漏数据的情况？
参考答案：
对表结构有要求， 我这边试的结果是要满足这些条件
● 不使用 blob 字段
● 不用 char 类型字段做主键
● 建表须有主键
● 不要用 double 类型做主键
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/584648
问题三：Flink CDC有没有新版的grafana dashboard，2021的好像有很多过时了？
Flink CDC有没有新版的grafana dashboard，2021的好像有很多过时了？
参考答案：
对于Flink CDC的新版Grafana仪表盘，我无法直接提供下载链接或详细信息。但可以告诉你的是，Flink CDC是Apache Flink的一组源连接器，使用变更数据捕获（CDC）从不同的数据库中摄取更改。Flink CDC 2.0.0版本已经正式发布。
Flink自身提供了Prometheus导出器，你可以使用它来创建Flink仪表板。这个仪表板可以帮助你实时监控Flink任务的状态，比如任务是否运行正常，是否存在反压，以及任务使用的内存、CPU等情况。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/584647
问题四：Flink CDC不支持的字段类型怎么处理？
Flink CDC不支持的字段类型怎么处理？ 比如要写入的pgsql 字段类型是point 我给的类型是string 他写入时没法转换为point，并且会报错
参考答案：
Flink CDC 支持的字段类型与 PostgreSQL 中的字段类型之间存在一些差异。对于不支持的字段类型，你可以尝试以下方法进行处理：
- 自定义转换器：你可以编写一个自定义的转换器，将 Flink CDC 支持的类型转换为 PostgreSQL 支持的类型。例如，你可以创建一个将字符串转换为 Point 类型的转换器。
- 使用默认值：如果 PostgreSQL 支持该字段类型，你可以在 Flink CDC 的配置中为该字段指定一个默认值。这样，在数据转换过程中，如果遇到不支持的字段类型，Flink CDC 会使用这个默认值进行替换。
- 忽略不支持的字段：如果你确定 PostgreSQL 数据库中的某些字段不需要同步到其他系统，你可以在 Flink CDC 的配置中将这些字段设置为忽略。这样，Flink CDC 在处理数据时会跳过这些字段，不会报错。
- 升级 Flink CDC 和 PostgreSQL 版本：如果以上方法都无法解决问题，你可以考虑升级 Flink CDC 和 PostgreSQL 的版本，以获得对更多字段类型的支持。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/584644
问题五：flink cdc 3.0 同步mysql 数据，怎么配置排除某列？
flink cdc 3.0 同步mysql 数据，怎么配置排除某列？
参考答案：
debezium.column.exclude.list: databaseName.tableName.columnName 
这是整库同步的用法，直接搬debezium的配置排查
关于本问题的更多回答可点击进行查看：
