Hi Team - I am currently working on integrating Flink with Apicurio Schema registry. So is there any documentation that can guide me with the appropriate setup and libraries required to make the integration work? Any suggestions are appreciated.

can you provide a bit more info on what you're trying to do?

Hi @RJ Garcia - I have Debezium CDC to capture data from Postgres db and Apicurio registry to store the schema information for the tables. Now I am using flink to capture data from kafka topics which contains reference for schema id in Schema registry. So without schema registry I am able to capture data in flink sql using below example CREATE TABLE orders ( id VARCHAR, ordernumber varchar ) WITH ( 'connector' = 'kafka', 'topic' = 'debezium.public.orders', 'properties.bootstrap.servers' = 'kafka:9092', 'scan.startup.mode' = 'earliest-offset', 'format' = 'debezium-json', 'debezium-json.schema-include' = 'true' ); How can i do the same Apicurio schema registry. What libraries and config changes required to achieve it? I am using Flink 2.2

https://www.apicur.io/registry/docs/apicurio-registry/3.2.x/getting-started/assembly-using-flink-catalog.html - have you looked at this?