Skip to content

Commit 3c76521

Browse files
chore: add zookeeper curator config logging
1 parent 2ef3282 commit 3c76521

File tree

1 file changed

+16
-1
lines changed

1 file changed

+16
-1
lines changed

newm-server/src/main/kotlin/io/newm/server/curator/CuratorInstall.kt

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,21 +1,36 @@
11
package io.newm.server.curator
22

3+
import io.github.oshai.kotlinlogging.KotlinLogging
34
import io.ktor.server.application.Application
45
import io.ktor.server.application.install
56
import io.newm.server.curator.support.CuratorPlugin
67
import io.newm.shared.ktx.getBoolean
78
import io.newm.shared.ktx.getConfigChild
89
import io.newm.shared.ktx.getInt
910
import io.newm.shared.ktx.getString
11+
import kotlin.io.path.Path
12+
import kotlin.io.path.readText
1013
import org.apache.curator.ensemble.fixed.FixedEnsembleProvider
1114
import org.apache.curator.retry.ExponentialBackoffRetry
1215

1316
fun Application.installCurator() {
17+
val log = KotlinLogging.logger { }
1418
val config = environment.getConfigChild("curator")
1519
if (config.getBoolean("enabled")) {
1620
install(CuratorPlugin) {
1721
ensembleProvider(
18-
FixedEnsembleProvider(config.getString("connectionString"), false),
22+
FixedEnsembleProvider(
23+
config.getString("connectionString").also { connectionString ->
24+
log.info {
25+
"Using Zookeeper connection string: '$connectionString', contents: ${
26+
Path(
27+
connectionString
28+
).readText()
29+
}"
30+
}
31+
},
32+
false
33+
),
1934
)
2035
retryPolicy(ExponentialBackoffRetry(config.getInt("baseSleepTime"), config.getInt("maxRetries")))
2136
}

0 commit comments

Comments
 (0)