Flink CDC有没有 sqlserver同步es的案例？

当然有，在 Flink 中可以直接使用 SQL Server CDC 功能与 Elasticsearch 进行实时同步。以下是具体的案例：

CREATE TABLE users (
id INT,
name STRING,
age INT,
PRIMARY KEY (id)
) WITH (
connector.type='jdbc',
connector.url='jdbc:mysql://localhost:3306/flink_test',
connector.table-name='users',
connector.driver='com.microsoft.sqlserver.jdbc.SQLServerDriver',
connector.username='sa',
connector.password='password',
connector.property-version='1'
);

接着将数据写入 Elasticsearch：

INSERT INTO elasticsearch.users_table
SELECT id, name, age FROM source_users;

Flink CDC支持将数据从SQL Server同步到Elasticsearch。首先，您需要安装支持CDC功能的SQL Server（例如，SQL Server 2008或更高版本），并开启SQL Server代理。然后，可以使用Flink CDC的sqlserver-cdc connector读取SQL Server中的数据变更，并通过Elasticsearch的JDBC Connector将这些变更写入到Elasticsearch中。

在实现过程中，Flink提供了丰富的操作符和API，可以满足各种数据处理需求，具有良好的可扩展性和容错性。同时，由于Flink CDC基于changelog机制，因此既可以处理全量数据，也可以处理增量数据，使得数据同步更加高效和准确。

https://ververica.github.io/flink-cdc-connectors/master/content/quickstart/sqlserver-tutorial.html，此回答整理自钉群“Flink CDC 社区”