Logs - embeddedkafka/embedded-kafka - Community Build Dashboard

1##################################

2Clonning https://github.com/embeddedkafka/embedded-kafka.git into /build/repo using revision v4.1.0

3##################################

4Note: switching to 'e6efcb04c31a5e6c0200ec2a2c483ec746c6cd2d'.

5

6You are in 'detached HEAD' state. You can look around, make experimental

7changes and commit them, and you can discard any commits you make in this

8state without impacting any branches by switching back to a branch.

9

10If you want to create a new branch to retain commits you create, you may

11do so (now or later) by using -c with the switch command. Example:

12

13 git switch -c <new-branch-name>

14

15Or undo this operation with:

16

17 git switch -

18

19Turn off this advice by setting config variable advice.detachedHead to false

20

21Would override fixed Scala version: 3.3.6

22----

23Preparing build for 3.8.0-RC3-bin-20251221-04feaed

24Scala binary version found: 3.8

25Implicitly using source version 3.8

26Scala binary version found: 3.8

27Implicitly using source version 3.8

28Would try to apply common scalacOption (best-effort, sbt/mill only):

29Append: ,REQUIRE:-source:3.8

30Remove: ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

31

32Try apply source patch:

33Path: project/Dependencies.scala

34Pattern: val Scala3 = "3.3.6"

35Replacement: val Scala3 = "3.8.0-RC3-bin-20251221-04feaed"

36Starting compilation server

37Compiling project (Scala 3.7.3, JVM (17))

38Compiled project (Scala 3.7.3, JVM (17))

39Successfully applied pattern 'val Scala3 = "3.3.6"' in project/Dependencies.scala

40----

41Starting build for 3.8.0-RC3-bin-20251221-04feaed

42Execute tests: false

43sbt project found:

44No prepare script found for project embeddedkafka/embedded-kafka

45##################################

46Scala version: 3.8.0-RC3-bin-20251221-04feaed

47Targets: io.github.embeddedkafka%embedded-kafka io.github.embeddedkafka%embedded-kafka-connect io.github.embeddedkafka%embedded-kafka-streams

48Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":[],"sourcePatches":[{"path":"project/Dependencies.scala","pattern":"val Scala3 = \"3.3.6\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}

49##################################

50Using extra scalacOptions: ,REQUIRE:-source:3.8

51Filtering out scalacOptions: ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

52[sbt_options] declare -a sbt_options=()

53[process_args] java_version = '17'

54[copyRt] java9_rt = '/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_17_0_8/rt.jar'

55# Executing command line:

56java

57-Dfile.encoding=UTF-8

58-Dcommunitybuild.scala=3.8.0-RC3-bin-20251221-04feaed

59-Dcommunitybuild.project.dependencies.add=

60-Xmx7G

61-Xms4G

62-Xss8M

63-Dsbt.script=/root/.sdkman/candidates/sbt/current/bin/sbt

64-Dscala.ext.dirs=/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_17_0_8

65-jar

66/root/.sdkman/candidates/sbt/1.11.5/bin/sbt-launch.jar

67"setCrossScalaVersions 3.8.0-RC3-bin-20251221-04feaed"

68"++3.8.0-RC3-bin-20251221-04feaed -v"

69"mapScalacOptions ",REQUIRE:-source:3.8,-Wconf:msg=can be rewritten automatically under:s" ",-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e""

70"set every credentials := Nil"

71"excludeLibraryDependency com.github.ghik:zerowaste_{scalaVersion} com.olegpy:better-monadic-for_3 org.polyvariant:better-tostring_{scalaVersion} org.wartremover:wartremover_{scalaVersion}"

72"removeScalacOptionsStartingWith -P:wartremover"

73

74moduleMappings

75"runBuild 3.8.0-RC3-bin-20251221-04feaed """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":[],"sourcePatches":[{"path":"project/Dependencies.scala","pattern":"val Scala3 = \"3.3.6\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}""" io.github.embeddedkafka%embedded-kafka io.github.embeddedkafka%embedded-kafka-connect io.github.embeddedkafka%embedded-kafka-streams"

76

77[info] welcome to sbt 1.11.5 (Eclipse Adoptium Java 17.0.8)

78[info] loading settings for project repo-build from akka.sbt, plugins.sbt...

79[info] loading project definition from /build/repo/project

80[info] compiling 3 Scala sources to /build/repo/project/target/scala-2.12/sbt-1.0/classes ...

81[info] Non-compiled module 'compiler-bridge_2.12' for Scala 2.12.20. Compiling...

82[info] Compilation completed in 8.573s.

83[info] done compiling

84[info] loading settings for project root from build.sbt...

85[info] set current project to embedded-kafka-root (in build file:/build/repo/)

86[warn] there's a key that's not used by any other settings/tasks:

87[warn]

88[warn] * ThisBuild / parallelExecution

89[warn] +- /build/repo/build.sbt:3

90[warn]

91[warn] note: a setting might still be used by a command; to exclude a key from this `lintUnused` check

92[warn] either append it to `Global / excludeLintKeys` or call .withRank(KeyRanks.Invisible) on the key

93Execute setCrossScalaVersions: 3.8.0-RC3-bin-20251221-04feaed

94OpenCB::Changing crossVersion 3.8.0-RC3-bin-20251221-04feaed -> 3.8.0-RC3-bin-20251221-04feaed in kafkaStreams/crossScalaVersions

95OpenCB::Changing crossVersion 3.8.0-RC3-bin-20251221-04feaed -> 3.8.0-RC3-bin-20251221-04feaed in embeddedKafka/crossScalaVersions

96OpenCB::Changing crossVersion 3.8.0-RC3-bin-20251221-04feaed -> 3.8.0-RC3-bin-20251221-04feaed in root/crossScalaVersions

97OpenCB::Changing crossVersion 3.8.0-RC3-bin-20251221-04feaed -> 3.8.0-RC3-bin-20251221-04feaed in kafkaConnect/crossScalaVersions

98[info] set current project to embedded-kafka-root (in build file:/build/repo/)

99[info] Setting Scala version to 3.8.0-RC3-bin-20251221-04feaed on 4 projects.

100[info] Switching Scala version on:

101[info] * root (2.13.16, 3.8.0-RC3-bin-20251221-04feaed)

102[info] embeddedKafka (2.13.16, 3.8.0-RC3-bin-20251221-04feaed)

103[info] kafkaStreams (2.13.16, 3.8.0-RC3-bin-20251221-04feaed)

104[info] kafkaConnect (2.13.16, 3.8.0-RC3-bin-20251221-04feaed)

105[info] Excluding projects:

106[info] Reapplying settings...

107[info] set current project to embedded-kafka-root (in build file:/build/repo/)

108Execute mapScalacOptions: ,REQUIRE:-source:3.8,-Wconf:msg=can be rewritten automatically under:s ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

109[info] Reapplying settings...

110[info] set current project to embedded-kafka-root (in build file:/build/repo/)

111[info] Defining Global / credentials, credentials and 2 others.

112[info] The new values will be used by Compile / scalafmtOnly, Global / pgpSelectPassphrase and 31 others.

113[info] Run `last` for details.

114[info] Reapplying settings...

115[info] set current project to embedded-kafka-root (in build file:/build/repo/)

116Execute excludeLibraryDependency: com.github.ghik:zerowaste_{scalaVersion} com.olegpy:better-monadic-for_3 org.polyvariant:better-tostring_{scalaVersion} org.wartremover:wartremover_{scalaVersion}

117[info] Reapplying settings...

118OpenCB::Failed to reapply settings in excludeLibraryDependency: Reference to undefined setting:

119

120 Global / allExcludeDependencies from Global / allExcludeDependencies (CommunityBuildPlugin.scala:331)

121 Did you mean allExcludeDependencies ?

122 , retry without global scopes

123[info] Reapplying settings...

124[info] set current project to embedded-kafka-root (in build file:/build/repo/)

125Execute removeScalacOptionsStartingWith: -P:wartremover

126[info] Reapplying settings...

127[info] set current project to embedded-kafka-root (in build file:/build/repo/)

128[success] Total time: 0 s, completed Dec 21, 2025, 9:49:22 PM

129Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":[],"sourcePatches":[{"path":"project/Dependencies.scala","pattern":"val Scala3 = \"3.3.6\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}

130Parsed config: Success(ProjectBuildConfig(ProjectsConfig(List(),Map()),CompileOnly,List()))

131Starting build...

132Projects: Set(embeddedKafka, kafkaConnect, kafkaStreams)

133Starting build for ProjectRef(file:/build/repo/,embeddedKafka) (embedded-kafka)... [0/3]

134OpenCB::Exclude Scala3 specific scalacOption `REQUIRE:-source:3.8` in Scala 2.12.20 module Global

135OpenCB::Filter out '-deprecation', matches setting pattern '^-?-deprecation'

136OpenCB::Filter out '-feature', matches setting pattern '^-?-feature'

137Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

138[info] scalafmt: Formatting 9 Scala sources (/build/repo/embedded-kafka)...

139[info] scalafmt: Formatting 13 Scala sources (/build/repo/embedded-kafka)...

140[info] compiling 13 Scala sources to /build/repo/embedded-kafka/target/scala-3.8.0-RC3-bin-20251221-04feaed/classes ...

141[info] done compiling

142[info] compiling 9 Scala sources to /build/repo/embedded-kafka/target/scala-3.8.0-RC3-bin-20251221-04feaed/test-classes ...

143[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:60:8

144[warn] 60 | records.iterator().hasNext shouldBe true

145[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

146[warn] | unused value of type org.scalatest.Assertion

147[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:86:8

148[warn] 86 | records.iterator().hasNext shouldBe true

149[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

150[warn] | unused value of type org.scalatest.Assertion

151[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:89:8

152[warn] 89 | record.value() shouldBe message

153[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

154[warn] | unused value of type org.scalatest.Assertion

155[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:111:8

156[warn] 111 | records.iterator().hasNext shouldBe true

157[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

158[warn] | unused value of type org.scalatest.Assertion

159[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:114:8

160[warn] 114 | record.key() shouldBe key

161[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^

162[warn] | unused value of type org.scalatest.Assertion

163[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:139:8

164[warn] 139 | records.hasNext shouldBe true

165[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

166[warn] | unused value of type org.scalatest.Assertion

167[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:142:8

168[warn] 142 | record1.key() shouldBe key1

169[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^

170[warn] | unused value of type org.scalatest.Assertion

171[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:143:8

172[warn] 143 | record1.value() shouldBe message1

173[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

174[warn] | unused value of type org.scalatest.Assertion

175[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:145:8

176[warn] 145 | records.hasNext shouldBe true

177[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

178[warn] | unused value of type org.scalatest.Assertion

179[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:147:8

180[warn] 147 | record2.key() shouldBe key2

181[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^

182[warn] | unused value of type org.scalatest.Assertion

183[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:162:6

184[warn] 162 | createCustomTopic(

185[warn] | ^

186[warn] | unused value of type scala.util.Try[Unit]

187[warn] 163 | topic,

188[warn] 164 | Map(

189[warn] 165 | TopicConfig.CLEANUP_POLICY_CONFIG -> TopicConfig.CLEANUP_POLICY_COMPACT

190[warn] 166 | )

191[warn] 167 | )

192[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:176:6

193[warn] 176 | createCustomTopic(

194[warn] | ^

195[warn] | unused value of type scala.util.Try[Unit]

196[warn] 177 | topic,

197[warn] 178 | Map(

198[warn] 179 | TopicConfig.CLEANUP_POLICY_CONFIG -> TopicConfig.CLEANUP_POLICY_COMPACT

199[warn] 180 | ),

200[warn] 181 | partitions = 2

201[warn] 182 | )

202[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:203:6

203[warn] 203 | deleteTopics(topics)

204[warn] | ^^^^^^^^^^^^^^^^^^^^

205[warn] | unused value of type scala.util.Try[Unit]

206[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:207:8

207[warn] 207 | assert(allTopicsOrFailure.isSuccess)

208[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

209[warn] | unused value of type org.scalatest.compatible.Assertion

210[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:235:6

211[warn] 235 | whenReady(

212[warn] | ^

213[warn] | unused value of type org.scalatest.compatible.Assertion

214[warn] 236 | producer.send(new ProducerRecord[String, String](topic, message))

215[warn] 237 | ) { _ => consumeFirstStringMessageFrom(topic) shouldBe message }

216[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:268:6

217[warn] 268 | consumedMessages.toSet shouldEqual messages

218[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

219[warn] | unused value of type org.scalatest.Assertion

220[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:301:6

221[warn] 301 | whenReady(

222[warn] | ^

223[warn] | unused value of type org.scalatest.compatible.Assertion

224[warn] 302 | producer.send(new ProducerRecord[String, String](topic, message))

225[warn] 303 | ) { _ =>

226[warn] 304 | consumeFirstMessageFrom[Array[Byte]](topic) shouldBe message.getBytes

227[warn] 305 | }

228[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:324:6

229[warn] 324 | whenReady(producer.send(new ProducerRecord(topic, message))) { _ =>

230[warn] | ^

231[warn] | unused value of type org.scalatest.compatible.Assertion

232[warn] 325 | consumeFirstMessageFrom[TestClass](topic) shouldBe message

233[warn] 326 | }

234[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:359:8

235[warn] 359 | k shouldBe key.getBytes

236[warn] | ^^^^^^^^^^^^^^^^^^^^^^^

237[warn] | unused value of type org.scalatest.Assertion

238[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:382:6

239[warn] 382 | whenReady(producer.send(new ProducerRecord(topic, key, message))) { _ =>

240[warn] | ^

241[warn] | unused value of type org.scalatest.compatible.Assertion

242[warn] 383 | consumeFirstKeyedMessageFrom[TestClass, TestClass](

243[warn] 384 | topic

244[warn] 385 | ) shouldBe key -> message

245[warn] 386 | }

246[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:408:6

247[warn] 408 | whenReady(producer.send(new ProducerRecord(topic, key, message))) { _ =>

248[warn] | ^

249[warn] | unused value of type org.scalatest.compatible.Assertion

250[warn] 409 | consumeFirstKeyedMessageFrom[String, TestClass](

251[warn] 410 | topic

252[warn] 411 | ) shouldBe key -> message

253[warn] 412 | }

254[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:445:6

255[warn] 445 | consumedMessages.toSet shouldEqual messages

256[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

257[warn] | unused value of type org.scalatest.Assertion

258[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:471:6

259[warn] 471 | a[TimeoutException] shouldBe thrownBy {

260[warn] | ^

261[warn] | unused value of type org.scalatest.Assertion

262[warn] 472 | consumeNumberStringMessagesFrom(topic, messages.size + 1)

263[warn] 473 | }

264[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:510:6

265[warn] 510 | consumedMessages.view

266[warn] | ^

267[warn] | unused value of type org.scalatest.Assertion

268[warn] 511 | .mapValues(_.sorted)

269[warn] 512 | .toMap shouldEqual topicMessagesMap

270[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:550:6

271[warn] 550 | consumedMessages.view

272[warn] | ^

273[warn] | unused value of type org.scalatest.Assertion

274[warn] 551 | .mapValues(_.sorted)

275[warn] 552 | .toMap shouldEqual topicMessagesMap

276[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:577:10

277[warn] 577 | records should have size 1

278[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^

279[warn] | unused value of type org.scalatest.Assertion

280[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala:579:10

281[warn] 579 | r.key shouldBe key

282[warn] | ^^^^^^^^^^^^^^^^^^

283[warn] | unused value of type org.scalatest.Assertion

284[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:26:8

285[warn] 26 | EmbeddedKafka.start()

286[warn] | ^^^^^^^^^^^^^^^^^^^^^

287[warn] | unused value of type io.github.embeddedkafka.EmbeddedK

288[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:28:28

289[warn] 28 | expectedServerStatus(defaultControllerPort, Available)

290[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

291[warn] | unused value of type org.scalatest.Assertion

292[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:29:28

293[warn] 29 | expectedServerStatus(defaultKafkaPort, Available)

294[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

295[warn] | unused value of type org.scalatest.Assertion

296[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:33:28

297[warn] 33 | expectedServerStatus(defaultKafkaPort, NotAvailable)

298[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

299[warn] | unused value of type org.scalatest.Assertion

300[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:40:8

301[warn] 40 | EmbeddedKafka.start()

302[warn] | ^^^^^^^^^^^^^^^^^^^^^

303[warn] | unused value of type io.github.embeddedkafka.EmbeddedK

304[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:42:28

305[warn] 42 | expectedServerStatus(12345, Available)

306[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

307[warn] | unused value of type org.scalatest.Assertion

308[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:43:28

309[warn] 43 | expectedServerStatus(54321, Available)

310[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

311[warn] | unused value of type org.scalatest.Assertion

312[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:52:29

313[warn] 52 | EmbeddedKafka.start()(

314[warn] | ^

315[warn] | unused value of type io.github.embeddedkafka.EmbeddedK

316[warn] 53 | EmbeddedKafkaConfig(kafkaPort = 8000, controllerPort = 8001)

317[warn] 54 | )

318[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:56:28

319[warn] 56 | expectedServerStatus(9001, Available)

320[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

321[warn] | unused value of type org.scalatest.Assertion

322[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:57:28

323[warn] 57 | expectedServerStatus(9000, Available)

324[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

325[warn] | unused value of type org.scalatest.Assertion

326[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:59:28

327[warn] 59 | expectedServerStatus(8001, Available)

328[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

329[warn] | unused value of type org.scalatest.Assertion

330[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:60:28

331[warn] 60 | expectedServerStatus(8000, Available)

332[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

333[warn] | unused value of type org.scalatest.Assertion

334[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:64:28

335[warn] 64 | expectedServerStatus(9000, NotAvailable)

336[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

337[warn] | unused value of type org.scalatest.Assertion

338[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:65:28

339[warn] 65 | expectedServerStatus(9001, NotAvailable)

340[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

341[warn] | unused value of type org.scalatest.Assertion

342[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:67:28

343[warn] 67 | expectedServerStatus(8000, Available)

344[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

345[warn] | unused value of type org.scalatest.Assertion

346[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:68:28

347[warn] 68 | expectedServerStatus(8001, Available)

348[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

349[warn] | unused value of type org.scalatest.Assertion

350[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:81:28

351[warn] 81 | expectedServerStatus(usedControllerPort, Available)

352[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

353[warn] | unused value of type org.scalatest.Assertion

354[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:82:28

355[warn] 82 | expectedServerStatus(usedKafkaPort, Available)

356[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

357[warn] | unused value of type org.scalatest.Assertion

358[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:84:8

359[warn] 84 | kafka.config.controllerPort should be(usedControllerPort)

360[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

361[warn] | unused value of type org.scalatest.Assertion

362[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:85:8

363[warn] 85 | kafka.config.kafkaPort should be(usedKafkaPort)

364[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

365[warn] | unused value of type org.scalatest.Assertion

366[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:89:28

367[warn] 89 | expectedServerStatus(usedKafkaPort, NotAvailable)

368[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

369[warn] | unused value of type org.scalatest.Assertion

370[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:111:28

371[warn] 111 | expectedServerStatus(someConfig.kafkaPort, Available)

372[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

373[warn] | unused value of type org.scalatest.Assertion

374[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:124:8

375[warn] 124 | moreRecords.size shouldBe 1

376[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^

377[warn] | unused value of type org.scalatest.Assertion

378[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:125:8

379[warn] 125 | moreRecords.headOption.value shouldBe someOtherMessage

380[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

381[warn] | unused value of type org.scalatest.Assertion

382[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:133:8

383[warn] 133 | EmbeddedKafka.start()

384[warn] | ^^^^^^^^^^^^^^^^^^^^^

385[warn] | unused value of type io.github.embeddedkafka.EmbeddedK

386[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaObjectSpec.scala:134:8

387[warn] 134 | EmbeddedKafka.isRunning shouldBe true

388[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

389[warn] | unused value of type org.scalatest.Assertion

390[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:18:10

391[warn] 18 | actualConfig shouldBe userDefinedConfig

392[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

393[warn] | unused value of type org.scalatest.Assertion

394[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:19:32

395[warn] 19 | everyServerIsAvailable(actualConfig)

396[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

397[warn] | unused value of type org.scalatest.Assertion

398[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:30:32

399[warn] 30 | everyServerIsAvailable(actualConfig1)

400[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

401[warn] | unused value of type org.scalatest.Assertion

402[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:32:10

403[warn] 32 | consumeFirstStringMessageFrom("topic")(

404[warn] | ^

405[warn] | unused value of type org.scalatest.Assertion

406[warn] 33 | actualConfig1

407[warn] 34 | ) shouldBe "message1"

408[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:37:36

409[warn] 37 | everyServerIsAvailable(actualConfig2)

410[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

411[warn] | unused value of type org.scalatest.Assertion

412[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:39:14

413[warn] 39 | consumeFirstStringMessageFrom("topic")(

414[warn] | ^

415[warn] | unused value of type org.scalatest.Assertion

416[warn] 40 | actualConfig2

417[warn] 41 | ) shouldBe "message2"

418[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:45:14

419[warn] 45 | allConfigs.map(_.kafkaPort).distinct should have size 3

420[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

421[warn] | unused value of type org.scalatest.Assertion

422[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:46:14

423[warn] 46 | allConfigs.map(_.controllerPort).distinct should have size 3

424[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

425[warn] | unused value of type org.scalatest.Assertion

426[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:47:14

427[warn] 47 | allConfigs

428[warn] | ^

429[warn] | unused value of type org.scalatest.Assertion

430[warn] 48 | .map(config =>

431[warn] 49 | EmbeddedKafkaConfigImpl(

432[warn] 50 | kafkaPort = 0,

433[warn] 51 | controllerPort = 0,

434[warn] 52 | config.customBrokerProperties,

435[warn] 53 | config.customProducerProperties,

436[warn] 54 | config.customConsumerProperties

437[warn] 55 | )

438[warn] 56 | )

439[warn] 57 | .distinct should have size 1

440[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:60:29

441[warn] 60 | noServerIsAvailable(actualConfig2)

442[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

443[warn] | unused value of type org.scalatest.Assertion

444[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:77:24

445[warn] 77 | expectedServerStatus(config.controllerPort, Available)

446[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

447[warn] | unused value of type org.scalatest.Assertion

448[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaOnFoundPortSpec.scala:82:24

449[warn] 82 | expectedServerStatus(config.controllerPort, NotAvailable)

450[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

451[warn] | unused value of type org.scalatest.Assertion

452[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaSpec.scala:21:8

453[warn] 21 | withRunningKafka {

454[warn] | ^

455[warn] | unused value of type org.scalatest.compatible.Assertion

456[warn] 22 | true shouldBe true

457[warn] 23 | }

458[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaSpec.scala:25:28

459[warn] 25 | expectedServerStatus(defaultControllerPort, NotAvailable)

460[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

461[warn] | unused value of type org.scalatest.Assertion

462[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaSpec.scala:30:8

463[warn] 30 | a[TestFailedException] shouldBe thrownBy {

464[warn] | ^

465[warn] | unused value of type org.scalatest.Assertion

466[warn] 31 | withRunningKafka {

467[warn] 32 | true shouldBe false

468[warn] 33 | }

469[warn] 34 | }

470[warn] -- [E176] Potential Issue Warning: /build/repo/embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaWithRunningKafkaSpec.scala:36:28

471[warn] 36 | expectedServerStatus(defaultControllerPort, NotAvailable)

472[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

473[warn] | unused value of type org.scalatest.Assertion

474[warn] 69 warnings found

475[info] done compiling

476Starting build for ProjectRef(file:/build/repo/,kafkaConnect) (embedded-kafka-connect)... [1/3]

477Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

478[info] scalafmt: Formatting 2 Scala sources (/build/repo/kafka-connect)...

479[info] scalafmt: Formatting 1 Scala sources (/build/repo/kafka-connect)...

480[info] compiling 2 Scala sources to /build/repo/kafka-connect/target/scala-3.8.0-RC3-bin-20251221-04feaed/classes ...

481[info] done compiling

482[info] compiling 1 Scala source to /build/repo/kafka-connect/target/scala-3.8.0-RC3-bin-20251221-04feaed/test-classes ...

483[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-connect/src/test/scala/io/github/embeddedkafka/connect/ExampleKafkaConnectSpec.scala:20:6

484[warn] 20 | startConnect(connectPort, offsets) {

485[warn] | ^

486[warn] | unused value of type org.scalatest.compatible.Assertion

487[warn] 21 | expectedServerStatus(connectPort, Available)

488[warn] 22 | }

489[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-connect/src/test/scala/io/github/embeddedkafka/connect/ExampleKafkaConnectSpec.scala:34:6

490[warn] 34 | startConnect(connectPort, offsets, extraConfig) {

491[warn] | ^

492[warn] | unused value of type org.scalatest.compatible.Assertion

493[warn] 35 | expectedServerStatus(connectPort, Available)

494[warn] 36 | }

495[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-connect/src/test/scala/io/github/embeddedkafka/connect/ExampleKafkaConnectSpec.scala:47:6

496[warn] 47 | a[ConfigException] shouldBe thrownBy {

497[warn] | ^

498[warn] | unused value of type org.scalatest.Assertion

499[warn] 48 | startConnect(connectPort, offsets, extraConfig) {}

500[warn] 49 | }

501[warn] three warnings found

502[info] done compiling

503Starting build for ProjectRef(file:/build/repo/,kafkaStreams) (embedded-kafka-streams)... [2/3]

504Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

505[info] scalafmt: Formatting 1 Scala sources (/build/repo/kafka-streams)...

506[info] scalafmt: Formatting 2 Scala sources (/build/repo/kafka-streams)...

507[info] compiling 2 Scala sources to /build/repo/kafka-streams/target/scala-3.8.0-RC3-bin-20251221-04feaed/classes ...

508[info] done compiling

509[info] compiling 1 Scala source to /build/repo/kafka-streams/target/scala-3.8.0-RC3-bin-20251221-04feaed/test-classes ...

510[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-streams/src/test/scala/io/github/embeddedkafka/streams/ExampleKafkaStreamsSpec.scala:44:8

511[warn] 44 | firstTwoMessages should be(

512[warn] | ^

513[warn] | unused value of type org.scalatest.Assertion

514[warn] 45 | Seq("hello" -> "world", "foo" -> "bar")

515[warn] 46 | )

516[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-streams/src/test/scala/io/github/embeddedkafka/streams/ExampleKafkaStreamsSpec.scala:76:8

517[warn] 76 | firstTwoMessages should be(

518[warn] | ^

519[warn] | unused value of type org.scalatest.Assertion

520[warn] 77 | Seq("hello" -> "world", "foo" -> "bar")

521[warn] 78 | )

522[warn] two warnings found

523[info] done compiling

524

525************************

526Build summary:

527[{

528 "module": "embedded-kafka",

529 "compile": {"status": "ok", "tookMs": 21649, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

530 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

531 "test-compile": {"status": "ok", "tookMs": 6400, "warnings": 69, "errors": 0, "sourceVersion": "3.8"},

532 "test": {"status": "skipped", "tookMs": 0, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},

533 "publish": {"status": "skipped", "tookMs": 0},

534 "metadata": {

535 "crossScalaVersions": ["2.13.16", "3.3.6"]

536}

537},{

538 "module": "embedded-kafka-connect",

539 "compile": {"status": "ok", "tookMs": 1030, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

540 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

541 "test-compile": {"status": "ok", "tookMs": 1247, "warnings": 3, "errors": 0, "sourceVersion": "3.8"},

542 "test": {"status": "skipped", "tookMs": 0, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},

543 "publish": {"status": "skipped", "tookMs": 0},

544 "metadata": {

545 "crossScalaVersions": ["2.13.16", "3.3.6"]

546}

547},{

548 "module": "embedded-kafka-streams",

549 "compile": {"status": "ok", "tookMs": 847, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

550 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

551 "test-compile": {"status": "ok", "tookMs": 1370, "warnings": 2, "errors": 0, "sourceVersion": "3.8"},

552 "test": {"status": "skipped", "tookMs": 0, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},

553 "publish": {"status": "skipped", "tookMs": 0},

554 "metadata": {

555 "crossScalaVersions": ["2.13.16", "3.3.6"]

556}

557}]

558************************

559[success] Total time: 115 s (0:01:55.0), completed Dec 21, 2025, 9:51:17 PM

560[0JChecking patch project/plugins.sbt...

561Checking patch project/Dependencies.scala...

562Checking patch build.sbt...

563Applied patch project/plugins.sbt cleanly.

564Applied patch project/Dependencies.scala cleanly.

565Applied patch build.sbt cleanly.

Build Logs