From 5ccbbab208b8a6df4527cdfb19dc8d262760f291 Mon Sep 17 00:00:00 2001 From: sp-gupta Date: Thu, 20 Feb 2025 14:52:48 +0530 Subject: [PATCH] Initial commit --- .../confluent/connect/elasticsearch/ElasticsearchClient.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/io/confluent/connect/elasticsearch/ElasticsearchClient.java b/src/main/java/io/confluent/connect/elasticsearch/ElasticsearchClient.java index f02fbd30f..069f4058e 100644 --- a/src/main/java/io/confluent/connect/elasticsearch/ElasticsearchClient.java +++ b/src/main/java/io/confluent/connect/elasticsearch/ElasticsearchClient.java @@ -89,7 +89,8 @@ public class ElasticsearchClient { "resource_already_exists_exception"; private static final String VERSION_CONFLICT_EXCEPTION = "version_conflict_engine_exception"; - + + private static final Set MALFORMED_DOC_ERRORS = new HashSet<>( Arrays.asList( "mapper_parsing_exception",