Description
I was trying out the new one-to-many KTable joins against some CDC data in Avro format and kept getting serialisation errors.
org.apache.kafka.common.errors.SerializationException: Error registering Avro schema: {"type":"record","name":"Key","namespace":"dbserver1.inventory.orders","fields":[ {"name":"order_number","type":"int"} ],"connect.name":"dbserver1.inventory.orders.Key"} Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema being registered is incompatible with an earlier schema; error code: 409
Both tables have avro keys of different types (one is an order key, the other a customer key).
This looks like it will cause issues.
They will both attempt to register schemas with the same subject to the schema registry which will fail a backward compatibility check.
I also noticed in the schema registry there were some subjects that didn't have the application id prefix. This is probably caused by this...
Where here repartitionTopicName doesn't have the application prefix.
Attachments
Issue Links
- relates to
-
KAFKA-3705 Support non-key joining in KTable
-
- Resolved
-
- links to