Hi, Community

当我使用flink命令启动一个使用了kafka-0.10 source 表的任务报了如下错误。 我使用的flink版本是1.11.2

> Could not find any factory for identifier 'kafka-0.10' that implements
'org.apache.flink.table.factories.DynamicTableSourceFactory' in the
classpath.

我确定我的jar文件里有以下相关目录和文件。

1. /META-INF/services/org.apache.flink.table.factories.TableFactory
content: 
org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactory

2. [自定义] /META-INF/services/org.apache.flink.table.factories.Factory
content: 
com.voxlearning.xue.continues.sink.clickhouse.ClickHouseDynamicTableFactory

3. org/apache/flink/streaming/connectors/kafka
content: Kafka010TableSourceSinkFactory.class

所以,我还忽略了什么排查点来确认问题呢? 如果需要任何额外信息请让我知道,谢谢。

-- 

*Best Regards*
*Jeremy Mei*

回复