Flink CDC中这个使用什么？init 会全量的往 elasticsearch 添加数据 。

在 Flink CDC 中，你可以使用 Flink 的 Elasticsearch Connector 来将数据从 CDC 捕获并全量地写入 Elasticsearch。

以下是一种可能的实现方式：

配置 Flink CDC 连接器：首先，你需要配置 Flink CDC 连接器，以捕获数据变更。这包括指定要监视的数据库和表，以及其他必要的连接器配置参数。你可以使用适合你数据库的 CDC 连接器，例如 MySQL CDC Connector、Debezium Connector 等。

配置 Flink Elasticsearch Connector：接下来，配置 Flink 的 Elasticsearch Connector，以将捕获的数据写入 Elasticsearch。你需要指定 Elasticsearch 的主机、索引名称、类型映射等配置。确保连接器的版本与你使用的 Flink 版本兼容。

实现 Flink 作业：创建一个 Flink 作业来将 CDC 数据从连接器传输到 Elasticsearch 连接器。你可以使用 Flink 的 DataStream API 或 Table API 来定义数据流转换和操作。

使用 DataStream API：通过创建一个 DataStream 对象，将 CDC 连接器输出的数据流传递给 Elasticsearch 连接器。在数据流上应用适当的转换和映射，以确保数据正确地写入 Elasticsearch。

使用 Table API：将 CDC 连接器输出的数据流注册为一个表，并使用 Table API 进行转换和操作。然后，将转换后的结果写入 Elasticsearch 连接器。

启动和执行作业：将定义好的 Flink 作业提交到 Flink 集群中，并启动作业执行。Flink 将从 CDC 连接器中读取数据变更，并将其写入 Elasticsearch 连接器，实现数据的全量写入。

你可以在flink的代码里用一些spring的部分功能 比如 spring-jdbc，spring-el等等。你要以flink为主 去集成别的而不是以springboot为主集成flink。此回答整理至钉群“Flink CDC 社区”。