SQL API 读取Kafka数据实时写入Iceberg表从Kafka中实时读取数据写入到Iceberg表中,操作步骤如下:一、首先需要创建对应的Iceberg表StreamExecutionEnvironment...hadoop_iceberg.iceberg_db.flink_iceberg_tbl3(id int,name string,age int,loc string) partitioned by (loc)");二、编写代码读取Kafka数据实时写入...OPTIONS 选项 configuration.setBoolean("table.dynamic-table-options.enabled", true); //5.写入数据到表...:1,zs,18,beijing2,ls,19,shanghai3,ww,20,beijing4,ml,21,shanghai我们可以看到控制台上有对应实时数据输出,查看对应的Icberg HDFS目录...,数据写入成功。