Flink CDC 出现null值的情况，请问下null值怎么过滤掉，在进入kafka前？

在Flink CDC中，可以使用where条件来过滤数据。如果出现了null值，可以在where条件中添加相应的过滤规则，例如：

SELECT * FROM my_table WHERE column1 IS NOT NULL AND column2 > 0;

这样就能够过滤掉column1为null或者column2小于等于0的数据。

另外，如果你使用的是upsert-kafka模式，可以在写入Kafka之前对数据进行过滤。具体来说，可以在将数据写入Kafka之前，先使用一个filter函数来过滤掉包含null值的数据。例如：

DataStream<MyRecord> filteredStream = sourceStream.filter(record -> record.getColumn1() != null && record.getColumn2() > 0);

这样就可以将包含null值的数据过滤掉，只将符合要求的数据写入Kafka。

别在抽取同步过程中 整逻辑进去，这种交给计算层 处理好了。 ，此回答整理自钉群“Flink CDC 社区”