如果kafka topic收到与kafka connector sql字段不符的记录，导致flink sql作业反序列化报错，该怎么办呢？
如果kafka topic收到与kafka connector sql字段不符的记录，导致flink[阿里云Kafka]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
=====这是一个广告位，招租中，联系qq 78315851====
同尘云，您身边的云智能顾问
如果kafka topic收到与kafka connector sql字段不符的记录，导致flink sql作业反序列化报错，该怎么办呢？
https://blog.51cto.com/u_15080019/2653841 自定义反序列化类
我建议你可以试试下面我总结的几点： 1. 尝试使用Flink的Schema Evolution功能，它可以自动处理字段类型变化，以及增加或删除字段。 2. 尝试使用Flink的TypeInformation功能，它可以检测Kafka topic中的记录，并自动调整Flink SQL作业的反序列化类型。 3. 尝试使用Kafka Connector的Schema Registry功能，它可以检测Kafka topic中的记录，并自动调整Flink SQL作业的反序列化类型。 4. 尝试使用Kafka Connector的Data Validation功能，它可以检测Kafka topic中的记录，并自动拒绝不符合要求的记录。