Connection configuration switched back to using metadata

Signed-off-by: Maxwell Brown <[email protected]>
opensearch-project · Jan 3, 2025 · 5d59aef · 5d59aef
1 parent b1202b0
commit 5d59aef
Show file tree

Hide file tree

Showing 3 changed files with 257 additions and 113 deletions.
diff --git a/...rch/dataprepper/plugins/sink/opensearch/configuration/AwsAuthenticationConfiguration.java b/...rch/dataprepper/plugins/sink/opensearch/configuration/AwsAuthenticationConfiguration.java
@@ -11,11 +11,13 @@
 
 import java.util.Map;
 
+import static org.opensearch.dataprepper.plugins.sink.opensearch.configuration.OpenSearchSinkConfig.DEFAULT_AWS_REGION;
+
 public class AwsAuthenticationConfiguration {
 
     @JsonProperty("region")
     @Size(min = 1, message = "Region cannot be empty string")
-    private String awsRegion;
+    private String awsRegion = DEFAULT_AWS_REGION;
 
     @JsonProperty("sts_role_arn")
     @Size(min = 20, max = 2048, message = "awsStsRoleArn length should be between 1 and 2048 characters")

diff --git a/...rg/opensearch/dataprepper/plugins/sink/opensearch/configuration/OpenSearchSinkConfig.java b/...rg/opensearch/dataprepper/plugins/sink/opensearch/configuration/OpenSearchSinkConfig.java
@@ -18,7 +18,7 @@ public class OpenSearchSinkConfig {
     public static final boolean DEFAULT_ESTIMATE_BULK_SIZE_USING_COMPRESSION = false;
     public static final int DEFAULT_MAX_LOCAL_COMPRESSIONS_FOR_ESTIMATION = 2;
     public static final long DEFAULT_FLUSH_TIMEOUT = 60_000L;
-    private static final String DEFAULT_AWS_REGION = "us-east-1";
+    public static final String DEFAULT_AWS_REGION = "us-east-1";
     @Getter
     @JsonProperty("hosts")
     private List<String> hosts;