Hi all, I've implemented a simple RecordTranslator in order to decode an Avro message sent by a Kafka producer.
The interesting bit looks like the standard decoding example: SpecificDatumReader<User> reader = new SpecificDatumReader<User>(User.getClassSchema()); Decoder decoder = DecoderFactory.get().binaryDecoder(bytes, null); User user = reader.read(null, decoder); However `reader.read` throws an `IOException` in case of a decoding error. How am I supposed to deal with the error ? Logging a warning message and return `null` ? What would be the implications downstream ? Thanks for your help.
