Flink CDC用到这个这种模式构建的Source吗？

看起来你是在使用Flink的Kafka connector。在Flink 2.4.2中，Kafka connector的Schema字段默认是STRING类型，而不是INT类型。这可能是导致你看到的错误的原因。

在你的代码中，你试图将一个Long类型的值转换为String类型，这可能是因为你在Kafka中存储的是Long类型的值，但是在Flink中，你使用了STRING类型的Schema来读取这些值。

你可以尝试以下几种方法来解决这个问题：

1. 在你的Kafka producer中，将数据类型设置为INT类型，而不是Long类型。

2. 在你的Flink Kafka connector中，将Schema字段的类型设置为INT类型，而不是STRING类型。

3. 如果你的Kafka producer已经将数据类型设置为Long类型，并且你不能改变这个设置，那么你可能需要在Flink中添加一些额外的代码来处理这种类型转换。