Hanserwei/han-note
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(search):优化 Canal 数据同步逻辑

Browse Source 
- 移除未使用的 IndexResponse 导入
- 简化 Elasticsearch 索引写入操作，去除不必要的响应处理- 保持异常处理逻辑不变，确保错误日志记录完整性
This commit is contained in:
Hanserwei
2025-11-03 14:53:09 +08:00
parent 268a009c9b
commit 218f4c6974
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
han-note-search/src/main/java/com/hanserwei/hannote/search/canal/CanalSchedule.java
View File

@@ -3,7 +3,6 @@ package com.hanserwei.hannote.search.canal;
import co.elastic.clients.elasticsearch.ElasticsearchClient; import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch.core.BulkRequest; import co.elastic.clients.elasticsearch.core.BulkRequest;
import co.elastic.clients.elasticsearch.core.IndexRequest; import co.elastic.clients.elasticsearch.core.IndexRequest;
import co.elastic.clients.elasticsearch.core.IndexResponse;
import co.elastic.clients.elasticsearch.core.bulk.BulkOperation; import co.elastic.clients.elasticsearch.core.bulk.BulkOperation;
import com.alibaba.otter.canal.client.CanalConnector; import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.protocol.CanalEntry; import com.alibaba.otter.canal.protocol.CanalEntry;
@@ -304,7 +303,7 @@ public class CanalSchedule implements Runnable {
.document(recordMap)); .document(recordMap));
// 将数据写入 Elasticsearch 索引 // 将数据写入 Elasticsearch 索引
try { try {
IndexResponse response = client.index(request); client.index(request);
} catch (IOException e) { } catch (IOException e) {
log.error("写入 Elasticsearch 索引异常", e); log.error("写入 Elasticsearch 索引异常", e);
} }