From 39d2eb1063f2ef13f0feb99a019d5822a7d2c624 Mon Sep 17 00:00:00 2001
From: Hanserwei <2628273921@qq.com>
Date: Sun, 2 Nov 2025 19:03:26 +0800
Subject: [PATCH] =?UTF-8?q?feat(search):=20=E9=9B=86=E6=88=90=20Canal=20?=
 =?UTF-8?q?=E5=AE=9E=E7=8E=B0=E6=95=B0=E6=8D=AE=E5=BA=93=E5=8F=98=E6=9B=B4?=
 =?UTF-8?q?=E7=9B=91=E5=90=AC=E4=B8=8E=E8=AF=8D=E5=85=B8=E7=83=AD=E6=9B=B4?=
 =?UTF-8?q?=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 新增 Canal 客户端配置与连接管理
- 实现 Canal 数据订阅与消费调度任务
- 添加外部词典热更新接口与服务实现- 配置 Elasticsearch词典热更新支持
- 引入 Canal 相关依赖并统一版本管理- 启用 Spring 定时任务支持以驱动 Canal 消费- 增加项目词典以优化拼写检查准确性
---
 .../java/com/hanserwei/hannote/search/canal/CanalSchedule.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 088f6ae..e6a2828 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
@@ -50,6 +50,7 @@ public class CanalSchedule implements Runnable {
                     // 拉取数据为空，休眠 1s, 防止频繁拉取
                     TimeUnit.SECONDS.sleep(1);
                 } catch (InterruptedException e) {
+                    log.error("消费 Canal 批次数据异常", e);
                 }
             } else {
                 // 如果当前批次有数据，打印这批次中的数据条目
@@ -77,7 +78,7 @@ public class CanalSchedule implements Runnable {
                 continue;
             }
 
-            CanalEntry.RowChange rowChage = null;
+            CanalEntry.RowChange rowChage;
             try {
                 rowChage = CanalEntry.RowChange.parseFrom(entry.getStoreValue());
             } catch (Exception e) {