Jeremy Custenborder created KAFKA-4709:
------------------------------------------
Summary: Error message from Struct.validate() should include the
name of the offending field.
Key: KAFKA-4709
URL: https://issues.apache.org/jira/browse/KAFKA-4709
Project: Kafka
Issue Type: Improvement
Components: KafkaConnect
Reporter: Jeremy Custenborder
Assignee: Jeremy Custenborder
Priority: Minor
Take a look at this repro.
{code}
@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();
}
{code}
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.
{code}
org.apache.kafka.connect.errors.DataException: Invalid value: null used for
required field
{code}
The error message should include the field or fields in the error message.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)