diff --git a/main/pom.xml b/main/pom.xml index 845373f9..ac1180a7 100644 --- a/main/pom.xml +++ b/main/pom.xml @@ -51,7 +51,7 @@ 4.2.7.Final 1.16.0 0.2.0 - 8.1.0 + 8.1.1 4.38.0 2.14.0 1.5.23 diff --git a/main/runtime/src/test/java/org/elasticsoftware/akcestest/schemas/JsonSchemaTests.java b/main/runtime/src/test/java/org/elasticsoftware/akcestest/schemas/JsonSchemaTests.java index 15a45b3a..a9c9d923 100644 --- a/main/runtime/src/test/java/org/elasticsoftware/akcestest/schemas/JsonSchemaTests.java +++ b/main/runtime/src/test/java/org/elasticsoftware/akcestest/schemas/JsonSchemaTests.java @@ -88,14 +88,14 @@ public void testSchemaCompatibility() throws IOException { List differencesV2 = SchemaDiff.compare(schema1.rawSchema(), schema2.rawSchema()) .stream().filter(diff -> - !SchemaDiff.COMPATIBLE_CHANGES.contains(diff.getType()) && + !SchemaDiff.COMPATIBLE_CHANGES_STRICT.contains(diff.getType()) && !Difference.Type.REQUIRED_PROPERTY_ADDED_TO_UNOPEN_CONTENT_MODEL.equals(diff.getType())).toList(); assertEquals(0, differencesV2.size()); List differencesV3 = SchemaDiff.compare(schema2.rawSchema(), schema3.rawSchema()) .stream().filter(diff -> - !SchemaDiff.COMPATIBLE_CHANGES.contains(diff.getType()) && + !SchemaDiff.COMPATIBLE_CHANGES_STRICT.contains(diff.getType()) && !Difference.Type.REQUIRED_PROPERTY_ADDED_TO_UNOPEN_CONTENT_MODEL.equals(diff.getType())).toList(); assertEquals(0, differencesV3.size()); diff --git a/main/shared/src/main/java/org/elasticsoftware/akces/schemas/KafkaSchemaRegistry.java b/main/shared/src/main/java/org/elasticsoftware/akces/schemas/KafkaSchemaRegistry.java index 3da27658..b1c92f5d 100644 --- a/main/shared/src/main/java/org/elasticsoftware/akces/schemas/KafkaSchemaRegistry.java +++ b/main/shared/src/main/java/org/elasticsoftware/akces/schemas/KafkaSchemaRegistry.java @@ -229,7 +229,7 @@ private void validateBackwardCompatibility(String schemaName, SchemaType sche JsonSchema localSchema, JsonSchema previousSchema) { List differences = SchemaDiff.compare(previousSchema.rawSchema(), localSchema.rawSchema()) .stream().filter(diff -> - !SchemaDiff.COMPATIBLE_CHANGES.contains(diff.getType()) && + !SchemaDiff.COMPATIBLE_CHANGES_STRICT.contains(diff.getType()) && !Difference.Type.REQUIRED_PROPERTY_ADDED_TO_UNOPEN_CONTENT_MODEL.equals(diff.getType())) .toList();