Flink CDC报这个错误？

Caused by: java.lang.ClassCastException: org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.ConsumerRecords cannot be cast to org.apache.flink.connector.kafka.source.KafkaSource.OffsetAndMetadata

这个错误是由于 Flink CDC 使用的是 Flink 1.11 版本的 Kafka Connector，而 Kafka 2.7.0 版本对 KafkaSource.OffsetAndMetadata 的字段顺序做了调整，导致 Flink 1.11 版本的 Kafka Connector 无法正确解析 Kafka 2.7.0 版本的 OffsetAndMetadata。

为了解决这个问题，您可以尝试以下方法：

升级 Flink 到 1.13 或更高版本。
使用 Flink 1.11 版本的 Kafka Connector，并在 flink-connector-kafka-0.11 项目中添加一个新的 OffsetAndMetadata 类，该类实现 org.apache.flink.connector.kafka.source.KafkaSource.OffsetAndMetadata 接口，并将字段顺序调整为与 Kafka 2.7.0 版本相同。
我建议您尝试第一种方法，即升级 Flink 到 1.13 或更高版本。