Is there a way to .set this default "org.apache.flink.formats.json.JsonDeserializationSchema" to ignore unknown field values within this code or do I have to make a custom deserializer to make it so? As of now if my "mega source topic"(50+data sources in one topic) has a field that is not recognized the job Flink errors out.

static void runJob() throws Exception {
        KafkaSource<Message> source =
                KafkaSource.<Message>builder()
                        .setBootstrapServers(BROKER)
                        .setTopics(TOPIC)
                        .setGroupId("KafkaExactlyOnceRecipeApplication")
                        .setStartingOffsets(
                                OffsetsInitializer.committedOffsets(OffsetResetStrategy.EARLIEST))
                        .setValueOnlyDeserializer(new JsonDeserializationSchema<>(Message.class))
                        .build();