Re: Re: Confluent Avro and Debezium formats - default schema name can be incompatible with registered schema name

2023-02-15 Thread Fruzsina Nagy
Hello Dawid, I created a pull request based on your suggestion. https://github.com/apache/flink/pull/21942 I'd appreciate it if you could have a look at it. Thanks in advance. Best regards, Fruzsina On Mon, Feb 6, 2023 at 11:34 AM Fruzsina Nagy wrote: > Hi Dawid, > Thanks for the

RE: Re: Confluent Avro and Debezium formats - default schema name can be incompatible with registered schema name

2023-02-06 Thread Fruzsina Nagy
d validate it maps properly to the > schema of the table (that is names of fields and their types match) and > use it instead of the generated one. > > What do you think about that approach? > > Best, > > Dawid > > On 26/01/2023 11:29, Fruzsina Nagy wrote: > > H

Confluent Avro and Debezium formats - default schema name can be incompatible with registered schema name

2023-01-26 Thread Fruzsina Nagy
Hi everyone, I have come across the below issue, while experimenting with the Confluent registry and avro-confluent, debezium-avro-confluent formats. Please let me know your thoughts on it. Should this issue be addressed? Thanks in advance, Fruzsina The use case Create a new topic on Confluent