Hi guys! I'm working on External Catalog for Confluent Kafka. The main idea to register the external catalog which provides the list of Kafka topics and execute SQL queries like : Select * form kafka.topic_name
I'm going to receive the table schema from Confluent schema registry. The main disadvantage is: we should have the topic name with the same name (prefix and postfix are accepted ) as this schema subject in Schema Registry. For example : topic: test-topic-prod schema subject: test-topic I would like to contribute this solution into the main Flink branch and would like to discuss the pros and cons of this approach. Best regards, Artsem
