关于Flink接收Kafka流数据使用Table API和SQL处理的问题

Question

你好，为什么我这边把你的代码复制过来报错呢？麻烦帮忙看看，包和依赖都导入了

Answer 1

你的包是不是导错了。删除你导入的包，把下面的包复制放你程序中。

import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.Kafka09TableSource;
import org.apache.flink.streaming.util.serialization.*;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.api.Types;
import org.apache.flink.table.api.java.StreamTableEnvironment;
import org.apache.flink.table.sources.TableSource;
import org.apache.flink.types.Row;
import java.util.Properties;