[jira] [Created] (KAFKA-12694) Specifying a struct-based defaultValue on a SchemaBuilder causes a DataException

["Chris Cranford (Jira)" <ji...@apache.org>]

Chris Cranford created KAFKA-12694:
--------------------------------------

             Summary: Specifying a struct-based defaultValue on a SchemaBuilder causes a DataException
                 Key: KAFKA-12694
                 URL: https://issues.apache.org/jira/browse/KAFKA-12694
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
    Affects Versions: 2.7.0
            Reporter: Chris Cranford


When making a call to {{SchemaBuilder#defaultValue(Object)}} a {{DataException}} will be thrown if the value if of type {{STRUCT}} due to schema mismatch.  This is because the method passes a reference of {{this}}, implying a {{SchemaBuilder}} to the {{ConnectSchema#validate}} method which later does an equality check which expects the passed schema to be an actual {{ConnectSchema}} rather than a {{SchemaBuilder}}.

{code}
Caused by: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default valueCaused by: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:131) at io.debezium.relational.TableSchemaBuilder.addField(TableSchemaBuilder.java:374) at io.debezium.relational.TableSchemaBuilder.lambda$create$2(TableSchemaBuilder.java:119) at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177) at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497) at io.debezium.relational.TableSchemaBuilder.create(TableSchemaBuilder.java:117) at io.debezium.relational.RelationalDatabaseSchema.buildAndRegisterSchema(RelationalDatabaseSchema.java:130) at io.debezium.connector.oracle.OracleDatabaseSchema.applySchemaChange(OracleDatabaseSchema.java:70) at io.debezium.pipeline.EventDispatcher$SchemaChangeEventReceiver.schemaChangeEvent(EventDispatcher.java:460) at io.debezium.relational.RelationalSnapshotChangeEventSource.lambda$createSchemaChangeEventsForTables$2(RelationalSnapshotChangeEventSource.java:273) ... 10 moreCaused by: org.apache.kafka.connect.errors.DataException: Struct schemas do not match. at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:252) at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:213) at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:129) ... 26 more
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)