Remove redundant call

Aiven-Open · Aug 6, 2024 · ac83525 · ac83525
1 parent f454235
commit ac83525
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/aiven/kafka/connect/opensearch/OpensearchSinkTask.java b/src/main/java/io/aiven/kafka/connect/opensearch/OpensearchSinkTask.java
@@ -148,7 +148,7 @@ private void ensureIndexOrDataStreamExists(final String index) {
                             LOGGER.info("Create data stream and template {}", index);
                             client.createIndexTemplateAndDataStream(userProvidedTemplate,
                                     config.dataStreamTimestampField());
-                        } else if (client.dataStreamIndexTemplateExists(userProvidedTemplate)) {
+                        } else {
                             LOGGER.info("Do not create data stream and template {}", index);
                         }
                     } else {