Flink CDC只监听一个字段 其他字段数据可以拿到吗？

Flink CDC可以监听多个字段，并且可以获取其他字段的数据。在Flink CDC中，可以通过定义数据模式来指定需要监听的字段，然后使用Flink SQL或Table API来查询这些字段的数据。

例如，假设有一个名为orders的表，包含以下字段：id、name、price和quantity。如果只想监听price字段的变化，可以在定义数据模式时仅指定该字段，如下所示：

DataStream<Row> orders = env.addSource(new FlinkCDCSource<>(
    "orders",
    new DebeziumDeserializationSchema.Builder()
        .with(...) // 配置source端信息
        .with("io.debezium.relationship.column.names", "pk") // 指定主键列名
        .with("value.converter", "io.debezium.converters.JsonConverter") // 指定值转换器
        .build(),
    new MySqlOffsetBackfiller()));

然后可以使用Flink SQL或Table API来查询其他字段的数据，例如：

// 使用Flink SQL查询所有订单的价格和数量总和
Table ordersTable = tEnv.fromDataStream(orders, "id, name, price, quantity");
Table result = tEnv.sqlQuery("SELECT price, SUM(quantity) as total_quantity FROM orders GROUP BY price");

或者使用Table API查询所有订单的价格和数量总和：

Table ordersTable = tEnv.fromDataStream(orders, "id, name, price, quantity");
Table result = tEnv.toRetractStream(ordersTable, Row.class).groupBy("price").select("price, SUM(quantity) as total_quantity");