java.lang.AbstractMethodError when implementing KafkaSerializationSchema

Posted by on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/java-lang-AbstractMethodError-when-implementing-KafkaSerializationSchema-tp35362.html

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

---

[hidden email]