huhuan created FLINK-35427: ------------------------------ Summary: Support fail-on-unknown-field config in json format Key: FLINK-35427 URL: https://issues.apache.org/jira/browse/FLINK-35427 Project: Flink Issue Type: Improvement Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile) Reporter: huhuan
In many cases, the consumer and producer of message queues come from different teams, or even different companies. As message consumer, sometimes it is difficult to subscribe updates on message format, which may result in data loss. We want to ensure the message format strictly matches the schema, if some field is missing or new field is added, it is better to fail the application so that we can notice and fix it quickly. In this case, a fail-on-unknown-field config for JSON format could be very helpful, especially when works with fail-on-missing-field. -- This message was sent by Atlassian Jira (v8.20.10#820010)