[KAFKA-4709] Error message from Struct.validate() should include the name of the offending field.

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 0.11.0.0
• Component/s: connect
• Assignee: Aegeaner
• Reporter: Jeremy Custenborder
• Created: 28/Jan/17 20:11
• Updated: 30/Mar/17 04:33
• Resolved: 16/Feb/17 21:44

Description

Take a look at this repro.

  @Test
  public void structValidate() {
    Schema schema = SchemaBuilder.struct()
        .field("one", Schema.STRING_SCHEMA)
        .field("two", Schema.STRING_SCHEMA)
        .field("three", Schema.STRING_SCHEMA)
        .build();

    Struct struct = new Struct(schema);
    struct.validate();
  }

Any one of the fields could be causing the issue. The following exception is thrown. This makes troubleshooting missing fields in connectors much more difficult.

org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field

The error message should include the field or fields in the error message.

Issue Links

• links to: GitHub Pull Request #2521