Flink CDC把原始库删除了以后重新创建了一个名称相同的库来着消费最新的binlog就没啥事了？

如果原始库被删除并重新创建为名称相同的新库，则CDC消费者可能无法正确识别该变化，并继续尝试从旧的库位置读取数据。这可能会导致各种问题，包括但不限于数据丢失、消费延迟等。

为了避免这种情况，建议在删除原始库之前停止CDC消费者的运行，或者在重新创建新库后更新CDC消费者的配置以指向新的库位置。这样可以确保消费者始终能够正确跟踪数据库的变化，并从中获取最新的数据。

默认全量启动会规避中间的数据格式不对的问题，此回答整理自钉群“Flink CDC 社区”

Flink CDC是一个强大的工具，能够作为各个数据源的source和sink，实时接入和实时推送数据。然而，当原始库被删除并重新创建一个名称相同的库时，虽然消费最新的binlog没有问题，但是如果换一个没有删除的库，数据能够读取到，但是会一直出现报错。这个报错信息对于理解问题可能有所帮助，但要找出问题的具体原因，还需要更多的上下文信息，例如Flink任务的配置、数据源的类型和状态、集群的资源使用情况等。

这种报错可能会影响数据的同步和处理，因为Flink CDC的核心是Change Data Capture（CDC）技术，它主要用于将关系型数据库中的数据同步到Flink上进行实时处理。如果在这个过程中出现报错，可能会导致数据同步失败，进而影响到后续的数据处理和分析。