Hello Edwin,
Would you mind sharing a simple FlinkSQL DDL for the table you are creating
with the kafka connector and dthe debezium-avro-confluent format?
Also, can you elaborate on the mechanism who publishes initially to the
schema registry and share the corresponding schema?
In a nutshell, th
Hi Edwin,
I'm suspecting that's because those fields are considered metadata which
are treated separately. There's
https://issues.apache.org/jira/browse/FLINK-20454 for adding the metadata
support for the Debezium format with a PR provided, but not yet reviewed.
If you could have a look at the PR
Hi guys,
I was trying to use flink sql to consume data from kafka source, the format of
which is debezium-avro-confluent. And I encountered a AvroTypeException saying
that "Found something, expecting union", where something is not a type but a
field that I defined in the schema registery.
So
