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 index 6a200e5b..1da90ef5 100644 --- 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 index 5db50403..13137a73 100644 --- 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") }