Hi everyone, I am facing an issue with my Apache Flink implementation when trying to use a custom class for Kafka deserialization. I am getting the following error:

Caused by: java.lang.AbstractMethodError: Receiver class spendreport.Deserializer.KafkaDeserializationSchemaWrapper2 does not define or inherit an implementation of the resolved method 'abstract void deserialize(org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.ConsumerRecord, org.apache.flink.util.Collector)' of interface org.apache.flink.connector.kafka.source.reader.deserializer.KafkaRecordDeserializationSchema.

Even though I have the method implemented with the correct signature, it seems to ignore it.