From fe4069e9e2d61561599beca8aecb3a526d93b073 Mon Sep 17 00:00:00 2001
From: dongdong <chenjiandongx@qq.com>
Date: Mon, 15 Jul 2024 10:27:55 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BF=AE=E5=A4=8D=20transfer=20ES=20?=
 =?UTF-8?q?=E7=B4=A2=E5=BC=95=20id=20=E9=87=8D=E5=A4=8D=E9=97=AE=E9=A2=98?=
 =?UTF-8?q?=20--story=3D118561918=20(#440)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pkg/transfer/elasticsearch/backend.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pkg/transfer/elasticsearch/backend.go b/pkg/transfer/elasticsearch/backend.go
index 2afaef9b9..0047b7153 100644
--- a/pkg/transfer/elasticsearch/backend.go
+++ b/pkg/transfer/elasticsearch/backend.go
@@ -48,6 +48,7 @@ func (b *BulkHandler) makeRecordID(values map[string]interface{}) string {
 
 	for _, key := range b.uniqueField {
 		buf.WriteString(conv.String(values[key]))
+		buf.WriteString("/")
 	}
 	n := xxhash.Sum64(buf.Bytes())
 	return strconv.FormatUint(n, 10)