【Flink实战系列】Lorg/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/ConsumerRecord；)Ljava/_serialize(ljava/lang/object;ljava/lang/long;)lorg/

java.lang.AbstractMethodError: Method flink/stream/deserialization/PoJoDeserializationSchema.deserialize(Lorg/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/ConsumerRecord;)Ljava/lang/Object; is abstract

背景介绍

Flink 消费 kafka 数据在使用自定义的反序列化类 PoJoDeserializationSchema 的时候遇到上面的报错，这里说明一下，如果你直接使用 SimpleStringSchema 反序列化是不会遇到这个问题的，另外一点，我这里使用的是 flink-sql-connector-kafka-1.15.0.jar 这个包，这里顺便在说一下 flink-connector-kafka-1.15.0.jar 和 flink-sql-connector-kafka-1.15.0.jar 这两个包的区别，因为我发现很多同学搞不清楚这两个包的关系，首先从名字上就能看出一个带 sql 一个不带，他们的使用场景是不一样的，如果我们是用 datastream api 开发的代码一般会使用 flink-connector-kafka-1.15.0.jar 这个包，如果我们是用 sql/table api 比如在 sql-client 里面通过 SQL 提交任务，那么我们需要添加 flink-sql-