我尝试使用pyflink的tabl api去连接kafka。但提交时异常报错：pyflink.util.exception.TableException:findAndCreateTableSource failed
通过DDL建立源表的配置上应该是没有问题的
请问这个问题你解决了吗？
若是通过StreamTableEnvironment.create(s_env,TableConfing())创建，即会报pyflink.util.exception.TableException:findAndCreateTableSource failed
若是通过StreamTableEnvironment.create(s_env,environment_settings=EnvironmentSettings.new_instance().use_blink_planner().build())创建，即会报unable to create a source for reading table 'default_catalog.default_database.XXXX'
查看一下 你的pyflink文件夹下面lib目录里有没有 kafka-connect的包，有的话 看一下 是不是和api文档一样的版本