@Override
  public Deserializer deserializer(String topic, Target type) {
    return new Deserializer() {
        @SneakyThrows
        @Override
        public DeserializeResult deserialize(RecordHeaders headers, byte[] data) {
            try {
              UnknownFieldSet unknownFields = UnknownFieldSet.parseFrom(data);
              return new DeserializeResult(unknownFields.toString(), DeserializeResult.Type.STRING, Map.of());
            } catch (Exception e) {
              throw new ValidationException(e.getMessage());
            }
        }
    };
  }
@Test
  void deserializeNullMessage() {
    var deserializer = serde.deserializer(DUMMY_TOPIC, Serde.Target.VALUE);
    assertThatThrownBy(() -> deserializer.deserialize(null, null))
        .isInstanceOf(ValidationException.class)
        .hasMessageContaining("Cannot read the array length");
  }