fix: schema compatibility compliance

hamba · May 18, 2024 · aff3955 · aff3955
1 parent dc715a4
commit aff3955
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/schema_compatibility.go b/schema_compatibility.go
@@ -179,7 +179,7 @@ func (c *SchemaCompatibility) match(reader, writer Schema) error {
 }
 
 func (c *SchemaCompatibility) checkSchemaName(reader, writer NamedSchema) error {
-	if reader.FullName() != writer.FullName() {
+	if reader.Name() != writer.Name() {
 		if c.contains(reader.Aliases(), writer.FullName()) {
 			return nil
 		}

diff --git a/schema_compatibility_test.go b/schema_compatibility_test.go
@@ -239,6 +239,12 @@ func TestSchemaCompatibility_Compatible(t *testing.T) {
 			writer:  `{"type":"record", "name":"test", "namespace": "org.hamba.avro", "fields":[{"name": "a", "type": "test"}]}`,
 			wantErr: assert.NoError,
 		},
+		{
+			name:    "Comparison with different namespaces",
+			writer:  `{"type":"record", "name":"Obj", "namespace": "ns", "fields":[{"name": "a", "type": "int"}]}`,
+			reader:  `{"type":"record", "name":"Obj", "fields":[{"name": "a", "type": "int"}]}`,
+			wantErr: assert.NoError,
+		},
 	}
 
 	for _, test := range tests {