[KAFKA-5550] Struct.put() should include the field name if validation fails

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: connect
• Assignee: Jeremy Custenborder
• Reporter: Jeremy Custenborder
• Created: 01/Jul/17 01:55
• Updated: 12/Feb/18 17:25
• Resolved: 12/Feb/18 17:25

Description

When calling struct.put() with an invalid value, the error message should include the field name.

@Test
public void testPutIncludesFieldName() {
    final String fieldName = "fieldName";
    Schema testSchema = SchemaBuilder.struct()
        .field(fieldName, Schema.STRING_SCHEMA);
    Struct struct = new Struct(testSchema);
    try {
        struct.put(fieldName, null);
    } catch (DataException ex) {
        assertEquals(
            "Invalid value: null used for required field: \"fieldName\", schema type: STRING",
            ex.getMessage()
        );
    }

}

Issue Links

• links to: GitHub Pull Request #3507
• links to: GitHub Pull Request #3507