要在Java中将MySQL数据同步到Elasticsearch，可以使用以下步骤：

1. 使用JDBC连接MySQL并执行查询。这需要加载MySQL JDBC驱动并使用Java代码创建连接。

2. 获取查询的结果集。使用Java代码遍历结果集并将其转换为Elasticsearch可以使用的JSON文档。

3. 使用Elasticsearch的Java API将JSON文档添加到索引。

以下是完整的Java代码示例，假设已有名为"products"的Elasticsearch索引，其中包含了从MySQL数据库中的"products"表同步的数据。

``` import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import org.elasticsearch.action.bulk.BulkRequest; import org.elasticsearch.action.bulk.BulkResponse; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestClient; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.common.xcontent.XContentType;

public class MySQLToElasticsearch { public static void main(String[] args) throws Exception { // 加载MySQL JDBC驱动 Class.forName("com.mysql.cj.jdbc.Driver");

// 创建MySQL连接
String mysqlUrl = "jdbc:mysql://localhost:3306/testdb";
String mysqlUser = "testuser";
String mysqlPassword = "testpass";
Connection mysqlConn = DriverManager.getConnection(mysqlUrl, mysqlUser, mysqlPassword);

// 执行MySQL查询
Statement mysqlStmt = mysqlConn.createStatement();
String mysqlQuery = "SELECT * FROM products";
ResultSet mysqlResult = mysqlStmt.executeQuery(mysqlQuery);

// 创建Elasticsearch客户端
RestHighLevelClient esClient = new RestHighLevelClient(
    RestClient.builder(
        new HttpHost("localhost", 9200, "http"),
        new HttpHost("localhost", 9201, "http")));

// 遍历MySQL结果集并添加文档到El