diff --git a/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java b/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java index 52baf3c3..36d0c672 100644 --- a/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java +++ b/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java @@ -209,7 +209,7 @@ public class ESSyncUtil { if (value.contains(";")) { separator = ";"; } else if (value.contains("|")) { - separator = "|"; + separator = "\\|"; } else if (value.contains("-")) { separator = "-"; }