介绍ElasticSearchSink使用方式及ES失败处理器，提供Flink 读写 ElasticSearch的源码解析

本篇文章为您介绍使用Flink CDC 3.0快速上手构建一条TeleDB-FlinkCDC-Doris数据同步链路

实时计算引擎哪家强？

本文档主要介绍如何将flink任务运行的metric发送到Prometheus，如何做相关的配置接入，以及性能看板展示（包括各个阶段输入输出qps 时延 反压成因 checkpoint延迟 state大小）等。

Flink 的 Table & SQL API 可以处理 SQL 语言编写的查询语句，但是这些查询需要嵌入用 Java 或 Scala 编写的 Table 程序中。此外，这些程序在提交到集群前需要用构建工具打包。这或多或少限制了 Java/Scala 程序员对 Flink 的使用。 SQL 客户端的目的是提供一种简单的方式来编写、调试和提交表程序到 Flink 集群上，不需写 Java 或 Scala 代码。SQL 客户端命令行界面（CLI） 能够在命令行中检索和可视化分布式应用的实时结果。