Merge pull request #43 from lalithkota/develop

SMT InsertBack: Default values edited.
OpenG2P · Oct 24, 2024 · 334ef32 · 334ef32
2 parents 67f7fa3 + 8a4785c
commit 334ef32
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...c/main/java/org/openg2p/reporting/kafka/connect/transforms/DynamicNewFieldInsertBack.java b/...c/main/java/org/openg2p/reporting/kafka/connect/transforms/DynamicNewFieldInsertBack.java
@@ -218,8 +218,8 @@ void close(){
         .define(ES_SECURITY_ENABLED_CONFIG, ConfigDef.Type.STRING, "", ConfigDef.Importance.HIGH, "Is Elasticsearch security enabled?")
         .define(ES_USERNAME_CONFIG, ConfigDef.Type.STRING, "", ConfigDef.Importance.HIGH, "Elasticsearch Username")
         .define(ES_PASSWORD_CONFIG, ConfigDef.Type.STRING, "", ConfigDef.Importance.HIGH, "Elasticsearch Password")
-        .define(ES_UPSERT_CONFIG, ConfigDef.Type.BOOLEAN, false, ConfigDef.Importance.HIGH, "Elasticsearch Update API doc_as_upsert param.")
-        .define(ES_MAX_RETRIES_CONFIG, ConfigDef.Type.INT, 10, ConfigDef.Importance.HIGH, "Elasticsearch Update API no of retries before fail.")
+        .define(ES_UPSERT_CONFIG, ConfigDef.Type.BOOLEAN, true, ConfigDef.Importance.HIGH, "Elasticsearch Update API doc_as_upsert param.")
+        .define(ES_MAX_RETRIES_CONFIG, ConfigDef.Type.INT, 1, ConfigDef.Importance.HIGH, "Elasticsearch Update API no of retries before fail.")
         .define(ES_RETRY_ON_CONFLICT_CONFIG, ConfigDef.Type.INT, 10, ConfigDef.Importance.HIGH, "Elasticsearch Update API retry_on_conflict param.");