5976637142

Committed 25 Aug 2023 01:43PM UTC coverage: 81.47% (+0.03%) from 81.438%

Build Type

push

github

Committed by

Commit Message

Fix migration in 1.11

Run Details

25 of 25 new or added lines in 2 files covered. (100.0%)

14865 of 18246 relevant lines covered (81.47%)

5.62 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

80.0

/utils/test-utils/src/main/scala/pl/touk/nussknacker/test/KafkaConfigProperties.scala

1	package pl.touk.nussknacker.test
2
3	object KafkaConfigProperties {
4
5	private val defaultPrefix = "kafka"	12✔
6
7	def bootstrapServersProperty(prefix: String = defaultPrefix): String = property(prefix, "bootstrap.servers")	12✔
8
9	def property(prefix: String, key: String): String = s"""$prefix.kafkaProperties.${escapeeKeyIfNeeded(key)}"""	6✔
10	def property(key: String): String = property(defaultPrefix, key)	8✔
11
12	private def escapeeKeyIfNeeded(key: String) = if (key.contains(".")) s""""$key"""" else key	×
13	}