Help about regis new union schema with redefine schema with error: "Can't redefine: schema_name"

[ThinhLe30]

Here is the problem
I have 2 schemas mapped with 2 events in my application:

{
			"type": "record",
			"namespace": "org.sample.avro.objects",
			"name": "AccountCreated",
			"doc": "An account is created",
			"fields": [
		{
				"name": "id",
				"type": "string",
				"doc": "The account id"
		},
		{
				"name": "fullName",
				"type": "string",
				"doc": "The account's full name"
		},
		{
				"name": "address",
				"type": {
			"type": "record",
			"name": "address",
			"fields": [
					{
				"name": "city",
				"type": "string"
					}
			]
				}
		}
			]
	}

and

              {
			"type": "record",
			"namespace": "org.sample.avro.objects",
			"name": "AccountUpdated",
			"doc": "An account is updated",
			"fields": [
		{
				"name": "id",
				"type": "string",
				"doc": "The account id"
		},
		{
				"name": "fullName",
				"type": "string",
				"doc": "The account's full name"
		},
		{
				"name": "address",
				"type": {
			"type": "record",
			"name": "address",
			"fields": [
					{
				"name": "city",
				"type": "string"
					}
			]
				}
		}
			]
	}

and when I register a new union schema like this

enc.schema, err = avro.NewUnionSchema(refSchemas)
	if err != nil {
		return nil, err
	}

enc.schemaID, _, err = client.CreateSchema(
		ctx,
		topic+"-value",
		enc.schema.String(),
		references...,
	)

var resp idPayload
	req := schemaPayload{Schema: schema, References: references}
	p := path.Join("subjects", subject, "versions")
	if err := c.request(ctx, http.MethodPost, p, req, &resp); err != nil {
		return 0, nil, err
	}

	sch, err := avro.Parse(schema)
	return resp.ID, sch, err

It's return error:

error creating topic's schema: Invalid schema {subject=my.other.topic-value,version=0,id=-1,schemaType=AVRO,references=[{name='org.sample.avro.objects.AccountCreated', subject='org.sample.avro.objects.AccountCreated', version=1}, {name='org.sample.avro.objects.AccountUpdated', subject='org.sample.avro.objects.AccountUpdated', version=1}],metadata=null,ruleSet=null,schema=["org.sample.avro.objects.AccountCreated","org.sample.avro.objects.AccountUpdated"]} with refs [{name='org.sample.avro.objects.AccountCreated', subject='org.sample.avro.objects.AccountCreated', version=1}, {name='org.sample.avro.objects.AccountUpdated', subject='org.sample.avro.objects.AccountUpdated', version=1}] of type AVRO, details: Can't redefine: org.sample.avro.objects.address

anyone can help me or any solution for register a UnionSchema, just let me know. Thanks a lot

[nrwiersma]

It seems the issue is the redeclaration of address: Can't redefine: org.sample.avro.objects.address. You should likely reference address in the second case.

[ThinhLe30]

Just do the test case that i assign different names to the address schema, likeaddress1 and address2, and it's pass the test :))

[ThinhLe30]

Anyway to reuse the previous schema and not get the error above?

[nrwiersma]

Assuming address is being passed as a reference, it should always be referenced, so you would need to parse the address separately, and always referenced as a string in your schema.

[ThinhLe30]

@nrwiersma are there any tool to split the main schema and the sub schema seperaly, like:

              {
			"type": "record",
			"namespace": "org.sample.avro.objects",
			"name": "AccountUpdated",
			"doc": "An account is updated",
			"fields": [
		{
				"name": "id",
				"type": "string",
				"doc": "The account id"
		},
		{
				"name": "fullName",
				"type": "string",
				"doc": "The account's full name"
		},
		{
				"name": "address",
				"type": {
			"type": "record",
			"name": "address",
			"fields": [
					{
				"name": "city",
				"type": "string"
					}
			]
				}
		}
			]
	}

to

              {
			"type": "record",
			"namespace": "org.sample.avro.objects",
			"name": "AccountUpdated",
			"doc": "An account is updated",
			"fields": [
		{
				"name": "id",
				"type": "string",
				"doc": "The account id"
		},
		{
				"name": "fullName",
				"type": "string",
				"doc": "The account's full name"
		},
		{
				"name": "address",
				"type": "org.sample.avro.objects.address"
		}
			]
	}

and

 {
			"type": "record",
			"name": "address",
			"namespace": "org.sample.avro.objects",
			"fields": [
					{
				"name": "city",
				"type": "string"
					}
			]
				}

[nrwiersma]

No, I dont know of any tool to do this.

[ThinhLe30]

I'm simply apply DFS to resolve this problem, thanks