java.lang.AbstractMethodError when implementing KafkaSerializationSchema

[wangl...@geekplus.com.cn]

public class MyKafkaSerializationSchema implements 
KafkaSerializationSchema<Tuple2<String, String>> {
    @Override
    public ProducerRecord<byte[], byte[]> serialize(Tuple2<String, String> o, 
@Nullable Long aLong) {
        ProducerRecord<byte[], byte[]> record = new ProducerRecord<>(o.f0,
            o.f1.getBytes(StandardCharsets.UTF_8));
        return record;
    }
}
FlinkKafkaProducer<Tuple2<String, String>> producer = new 
FlinkKafkaProducer<Tuple2<String, String>>(
    "default", new MyKafkaSerializationSchema(),
    prop2,Semantic.EXACTLY_ONCE);

But there's  error when runnng：

java.lang.AbstractMethodError: 
com.geekplus.flinketl.schema.MyKafkaSerializationSchema.serialize(Ljava/lang/Object;Ljava/lang/Long;)Lorg/apache/flink/kafka/shaded/org/apache/kafka/clients/producer/ProducerRecord;

Any suggestion on this？

Thanks，
Lei


wangl...@geekplus.com.cn