chore: update logging

neo4j-contrib · Sep 3, 2024 · d753983 · d753983
1 parent 4618fe6
commit d753983
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/sink/Neo4jSinkConnector.kt b/kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/sink/Neo4jSinkConnector.kt
@@ -36,7 +36,11 @@ class Neo4jSinkConnector: SinkConnector() {
         val migratedConfig = ConfigurationMigrator(settings).migrateToV51()
         val mapper = ObjectMapper()
         val jsonConfig = mapper.writeValueAsString(migratedConfig)
-        log.info("Migrated Neo4j Sink Connector '{}' configuration to v5.1 connector format: {}", settings["name"], jsonConfig)
+        log.info(
+            "The migrated settings for 5.1 version of Neo4j Sink Connector '{}' is: `{}`",
+            settings["name"],
+            jsonConfig
+        )
     }
 
     override fun version(): String {

diff --git a/kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/source/Neo4jSourceService.kt b/kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/source/Neo4jSourceService.kt
@@ -184,7 +184,11 @@ class Neo4jSourceService(private val config: Neo4jSourceConnectorConfig, offsetS
 
         val mapper = ObjectMapper()
         val jsonConfig = mapper.writeValueAsString(migratedConfig)
-        log.info("Migrated Neo4j Source Connector '{}' configuration to v5.1 connector format: {}", originalConfig["name"], jsonConfig)
+        log.info(
+            "The migrated settings for 5.1 version of Neo4j Source Connector '{}' is: `{}`",
+            originalConfig["name"],
+            jsonConfig
+        )
 
         log.info("Neo4j Source Service closed successfully")
     }