From 218f4c69740617562ce19e9ffa97a68cc2b749ac Mon Sep 17 00:00:00 2001
From: Hanserwei <2628273921@qq.com>
Date: Mon, 3 Nov 2025 14:53:09 +0800
Subject: [PATCH] =?UTF-8?q?refactor(search):=E4=BC=98=E5=8C=96=20Canal=20?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=90=8C=E6=AD=A5=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 移除未使用的 IndexResponse 导入
- 简化 Elasticsearch 索引写入操作，去除不必要的响应处理- 保持异常处理逻辑不变，确保错误日志记录完整性
---
 .../java/com/hanserwei/hannote/search/canal/CanalSchedule.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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