Fix log statements

Aiven-Open · Aug 6, 2024 · d8180d3 · d8180d3
1 parent ac83525
commit d8180d3
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/main/java/io/aiven/kafka/connect/opensearch/OpensearchSinkTask.java b/src/main/java/io/aiven/kafka/connect/opensearch/OpensearchSinkTask.java
@@ -145,11 +145,12 @@ private void ensureIndexOrDataStreamExists(final String index) {
                     if (config.dataStreamExistingIndexTemplateName().isPresent()) {
                         String userProvidedTemplate = config.dataStreamExistingIndexTemplateName().get();
                         if (!client.dataStreamIndexTemplateExists(userProvidedTemplate)) {
-                            LOGGER.info("Create data stream and template {}", index);
+                            LOGGER.info("Creating index template {} for data stream {}", userProvidedTemplate, index);
                             client.createIndexTemplateAndDataStream(userProvidedTemplate,
                                     config.dataStreamTimestampField());
                         } else {
-                            LOGGER.info("Do not create data stream and template {}", index);
+                            LOGGER.info("Using existing index template {} for data stream {}", userProvidedTemplate,
+                                    index);
                         }
                     } else {
                         LOGGER.info("Create data stream {}", index);