Flink CDC中同步数据到es的时候不能创建分词吧？

Flink CDC 可以同步数据到 ES 的时候创建分词。你可以使用 createIndexRequest() 方法在创建索引的时候指定分词器。

以下是一个使用 createIndexRequest() 方法创建分词器的例子：

public IndexRequest createIndexRequest(String indexName) {
IndexRequest request = new IndexRequest(indexName);
request.setSource(
"{\"index\":{\"analyzed\":true,\"analyzer\":\"standard\"},\"type\":\"mytype\"}",
XContentType.JSON);
return request;
}
在该例子中，我们使用 standard 分词器来创建索引。