我们以 EMR 为例，Flink SQL Client 默认是没有安装 kafka connector 的相关 Jar 包的，所以在 Flink SQL Client 中执行 Kafka 的建表语句时会报如下错误： org.apache.flink.table.api.ValidationException: Could not find any factory for identifier ‘upsert-kafka’ that implements ‘org.apache.flink.table.fa