Flink CDC中Flink能捕获这类转换异常么？

link CDC 不会捕获字段转换异常，你可以通过配置 cdc.field.converter.exception.handler 来处理这些异常。

以下是默认的异常处理器：

class DefaultFieldConverterExceptionHandler implements FieldConverterExceptionHandler {
@Override
public void handleException(
String sourceTopic,
String sourcePartition,
long sourceOffset,
String field,
String typeName,
Object value,
ClassCastException exception) {
logger.error("Failed to convert field '{}' in data record with topic {} partition {} offset {}: {}",
field, sourceTopic, sourcePartition, sourceOffset, exception);
}
}
你可以通过配置 cdc.field.converter.exception.handler.class 来替换默认的异常处理器。

以下是一个自定义的异常处理器：

class CustomFieldConverterExceptionHandler implements FieldConverterExceptionHandler {
@Override
public void handleException(
String sourceTopic,
String sourcePartition,
long sourceOffset,
String field,
String typeName,
Object value,
ClassCastException exception) {
// Do something with the exception, such as log it or rethrow it.
}
}
你可以在 Flink CDC 的配置文件中配置异常处理器：

cdc.field.converter.exception.handler.class = "com.example.CustomFieldConverterExceptionHandler"