Ferenc Csaky created FLINK-31085:
------------------------------------
Summary: Add schema option to confluent registry avro formats
Key: FLINK-31085
URL: https://issues.apache.org/jira/browse/FLINK-31085
Project: Flink
Issue Type: Improvement
Reporter: Ferenc Csaky
Fix For: 1.17.0
When using {{avro-confluent}} and {{debezium-avro-confluent}} formats with
schemas already defined in the Confluent Schema Registry, serialization fails,
because Flink uses a default name `record` when converting row types to avro
schema. So if the predefined schema has a different name, the serialization
schema will be incompatible with the registered schema due to name mismatch.
Check [this|https://lists.apache.org/thread/5xppmnqjqwfzxqo4gvd3lzz8wzs566zp]
thread about reproducing the issue.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
