文章目录 Flink系列文章 一、Table&SQLConnectors示例：Elasticsearch 1、maven依赖（java编码依赖） 2、创建Elasticsearch表并写入数据 3、连接器参数 4、特性 1）、Key处理 2）、动态索引 5、数据类型映射 二、FlinkSQL示例：将kafka数据写入es 1、依赖环境 2、创建表并提交任务 3、验证 1）、创建es表 2）、创建kafka表 3）、提交任务 4）、创建kafkatopic 5）、往kafkatopic中写入数据 6）、查看es中的数据 本文介绍了Elasticse...