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