Hi Team, Doing quick POC on reading Kafka via FlinkSQL, getting the following error -

Flink SQL> SELECT * FROM MyCatalog.MyDatabase.KafkaTable;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.

Available factory identifiers are:

blackhole
datagen
filesystem
print
python-input-format

Am I missing something here?

That indicates bat you haven’t added the Flink SQL Kafka connector JAR to your cluster

Add the jar file in lib folder or run ./sql-client —jar <jar file>