Build Logs

embeddedkafka/embedded-kafka • 3.8.0-RC3:2025-12-04

Errors

6

Warnings

368

Total Lines

637

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
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"
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
42Execute tests: true
43sbt project found:
44No prepare script found for project embeddedkafka/embedded-kafka
45##################################
46Scala version: 3.8.0-RC3
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":"full","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
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"
68"++3.8.0-RC3 -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 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","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.557s.
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
94OpenCB::Changing crossVersion 3.8.0-RC3 -> 3.8.0-RC3 in kafkaStreams/crossScalaVersions
95OpenCB::Changing crossVersion 3.8.0-RC3 -> 3.8.0-RC3 in embeddedKafka/crossScalaVersions
96OpenCB::Changing crossVersion 3.8.0-RC3 -> 3.8.0-RC3 in kafkaConnect/crossScalaVersions
97OpenCB::Changing crossVersion 3.8.0-RC3 -> 3.8.0-RC3 in root/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 on 4 projects.
100[info] Switching Scala version on:
101[info] * root (2.13.16, 3.8.0-RC3)
102[info] embeddedKafka (2.13.16, 3.8.0-RC3)
103[info] kafkaStreams (2.13.16, 3.8.0-RC3)
104[info] kafkaConnect (2.13.16, 3.8.0-RC3)
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 4, 2025, 3:38:45 PM
129Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":[],"sourcePatches":[{"path":"project/Dependencies.scala","pattern":"val Scala3 = \"3.3.6\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}
130Parsed config: Success(ProjectBuildConfig(ProjectsConfig(List(),Map()),Full,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 13 Scala sources (/build/repo/embedded-kafka)...
139[info] scalafmt: Formatting 9 Scala sources (/build/repo/embedded-kafka)...
140[info] compiling 13 Scala sources to /build/repo/embedded-kafka/target/scala-3.8.0-RC3/classes ...
141[info] done compiling
142[info] compiling 9 Scala sources to /build/repo/embedded-kafka/target/scala-3.8.0-RC3/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
476[info] EmbeddedKafkaUnavailableSpec:
477[info] the publishToKafka method
478[info] - should throw a KafkaUnavailableException when Kafka is unavailable when trying to publish
479[info] the consumeFirstStringMessageFrom method
480[info] - should throw a KafkaUnavailableException when there's no running instance of Kafka
481[info] EmbeddedKafkaWithRunningKafkaOnFoundPortSpec:
482[info] the withRunningKafkaOnFoundPort method
483[info] - should start and stop Kafka broker and controller successfully on non-zero ports
484[info] - should start and stop multiple Kafka broker and controller successfully on arbitrary available ports
485[info] - should work with a simple example using implicits
486[info] EmbeddedKafkaCustomConfigSpec:
487[info] the custom config
488[info] - should allow pass additional producer parameters
489[info] EmbeddedKafkaObjectSpec:
490[info] the EmbeddedKafka object
491[info] when invoking the start and stop methods
492[info] - should start and stop Kafka broker and controller on the default ports
493[info] - should start and stop Kafka broker and controller on different specified ports using an implicit configuration
494[info] - should start and stop a specific Kafka
495[info] - should start and stop Kafka broker and controller successfully on arbitrary available ports
496[info] - should start and stop multiple Kafka instances on specified ports
497[info] when invoking the isRunning method
498[info] - should return true when Kafka is running
499[info] EmbeddedKafkaWithRunningKafkaSpec:
500[info] the withRunningKafka method
501[info] - should start a Kafka broker on port 6001 by default
502[info] should stop Kafka successfully
503[info] - when the enclosed test passes
504[info] - when the enclosed test fails
505[info] - should start a Kafka broker on a specified port
506[info] - should start a Kafka controller on a specified port
507[info] EmbeddedKafkaMethodsSpec:
508[info] the publishToKafka method
509[info] - should publish synchronously a String message to Kafka
510[info] - should publish synchronously a String message with a header to Kafka
511[info] - should publish synchronously a String message with String key to Kafka
512[info] - should publish synchronously a batch of String messages with String keys to Kafka
513[info] the createCustomTopic method
514[info] - should create a topic with a custom configuration
515[info] - should create a topic with custom number of partitions
516[info] the deleteTopics method
517[info] - should either delete of mark for deletion a list of topics
518[info] the consumeFirstStringMessageFrom method
519[info] - should return a message published to a topic
520[info] - should consume only a single message when multiple messages have been published to a topic
521[info] - should throw a TimeoutExeption when a message is not available
522[info] the consumeFirstMessageFrom method
523[info] - should return a message published to a topic with implicit decoder
524[info] - should return a message published to a topic with custom decoder
525[info] the consumeFirstKeyedMessageFrom method
526[info] - should return a message published to a topic with implicit decoders
527[info] - should return a message published to a topic with custom decoders
528[info] - should return a message published to a topic with 2 different decoders
529[info] the consumeNumberStringMessagesFrom method
530[info] - should consume set number of messages when multiple messages have been published to a topic
531[info] - should timeout and throw a TimeoutException when n messages are not received in time
532[info] the consumeNumberMessagesFromTopics method
533[info] - should consume from multiple topics
534[info] the consumeNumberKeyedMessagesFromTopics method
535[info] - should consume from multiple topics
536[info] the consumer and producer loaner methods
537[info] - should loan consumer and producer
538Starting build for ProjectRef(file:/build/repo/,kafkaConnect) (embedded-kafka-connect)... [1/3]
539Compile 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
540[info] scalafmt: Formatting 2 Scala sources (/build/repo/kafka-connect)...
541[info] scalafmt: Formatting 1 Scala sources (/build/repo/kafka-connect)...
542[info] compiling 2 Scala sources to /build/repo/kafka-connect/target/scala-3.8.0-RC3/classes ...
543[info] done compiling
544[info] compiling 1 Scala source to /build/repo/kafka-connect/target/scala-3.8.0-RC3/test-classes ...
545[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-connect/src/test/scala/io/github/embeddedkafka/connect/ExampleKafkaConnectSpec.scala:20:6
546[warn] 20 | startConnect(connectPort, offsets) {
547[warn] | ^
548[warn] | unused value of type org.scalatest.compatible.Assertion
549[warn] 21 | expectedServerStatus(connectPort, Available)
550[warn] 22 | }
551[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-connect/src/test/scala/io/github/embeddedkafka/connect/ExampleKafkaConnectSpec.scala:34:6
552[warn] 34 | startConnect(connectPort, offsets, extraConfig) {
553[warn] | ^
554[warn] | unused value of type org.scalatest.compatible.Assertion
555[warn] 35 | expectedServerStatus(connectPort, Available)
556[warn] 36 | }
557[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-connect/src/test/scala/io/github/embeddedkafka/connect/ExampleKafkaConnectSpec.scala:47:6
558[warn] 47 | a[ConfigException] shouldBe thrownBy {
559[warn] | ^
560[warn] | unused value of type org.scalatest.Assertion
561[warn] 48 | startConnect(connectPort, offsets, extraConfig) {}
562[warn] 49 | }
563[warn] three warnings found
564[info] done compiling
565[info] ExampleKafkaConnectSpec:
566[info] A Kafka Connect test
567[info] - should start a Connect server on a specified port
568[info] - should start a Connect server with custom properties
569[info] - should fail to start a Connect server with invalid properties
570Starting build for ProjectRef(file:/build/repo/,kafkaStreams) (embedded-kafka-streams)... [2/3]
571Compile 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
572[info] scalafmt: Formatting 1 Scala sources (/build/repo/kafka-streams)...
573[info] scalafmt: Formatting 2 Scala sources (/build/repo/kafka-streams)...
574[info] compiling 2 Scala sources to /build/repo/kafka-streams/target/scala-3.8.0-RC3/classes ...
575[info] done compiling
576[info] compiling 1 Scala source to /build/repo/kafka-streams/target/scala-3.8.0-RC3/test-classes ...
577[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-streams/src/test/scala/io/github/embeddedkafka/streams/ExampleKafkaStreamsSpec.scala:44:8
578[warn] 44 | firstTwoMessages should be(
579[warn] | ^
580[warn] | unused value of type org.scalatest.Assertion
581[warn] 45 | Seq("hello" -> "world", "foo" -> "bar")
582[warn] 46 | )
583[warn] -- [E176] Potential Issue Warning: /build/repo/kafka-streams/src/test/scala/io/github/embeddedkafka/streams/ExampleKafkaStreamsSpec.scala:76:8
584[warn] 76 | firstTwoMessages should be(
585[warn] | ^
586[warn] | unused value of type org.scalatest.Assertion
587[warn] 77 | Seq("hello" -> "world", "foo" -> "bar")
588[warn] 78 | )
589[warn] two warnings found
590[info] done compiling
591[info] ExampleKafkaStreamsSpec:
592[info] A Kafka streams test
593[info] - should be easy to run with streams and consumer lifecycle management
594[info] - should be easy to run with streams on arbitrary available ports
595[info] - should allow support creating custom consumers
596
597************************
598Build summary:
599[{
600 "module": "embedded-kafka",
601 "compile": {"status": "ok", "tookMs": 23890, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},
602 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},
603 "test-compile": {"status": "ok", "tookMs": 6214, "warnings": 69, "errors": 0, "sourceVersion": "3.8"},
604 "test": {"status": "ok", "tookMs": 122923, "passed": 37, "failed": 0, "ignored": 0, "skipped": 0, "total": 37, "byFramework": [{"framework": "unknown", "stats": {"passed": 37, "failed": 0, "ignored": 0, "skipped": 0, "total": 37}}]},
605 "publish": {"status": "skipped", "tookMs": 0},
606 "metadata": {
607 "crossScalaVersions": ["2.13.16", "3.3.6"]
608}
609},{
610 "module": "embedded-kafka-connect",
611 "compile": {"status": "ok", "tookMs": 988, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},
612 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},
613 "test-compile": {"status": "ok", "tookMs": 1110, "warnings": 3, "errors": 0, "sourceVersion": "3.8"},
614 "test": {"status": "ok", "tookMs": 7662, "passed": 3, "failed": 0, "ignored": 0, "skipped": 0, "total": 3, "byFramework": [{"framework": "unknown", "stats": {"passed": 3, "failed": 0, "ignored": 0, "skipped": 0, "total": 3}}]},
615 "publish": {"status": "skipped", "tookMs": 0},
616 "metadata": {
617 "crossScalaVersions": ["2.13.16", "3.3.6"]
618}
619},{
620 "module": "embedded-kafka-streams",
621 "compile": {"status": "ok", "tookMs": 839, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},
622 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},
623 "test-compile": {"status": "ok", "tookMs": 1255, "warnings": 2, "errors": 0, "sourceVersion": "3.8"},
624 "test": {"status": "ok", "tookMs": 24915, "passed": 3, "failed": 0, "ignored": 0, "skipped": 0, "total": 3, "byFramework": [{"framework": "unknown", "stats": {"passed": 3, "failed": 0, "ignored": 0, "skipped": 0, "total": 3}}]},
625 "publish": {"status": "skipped", "tookMs": 0},
626 "metadata": {
627 "crossScalaVersions": ["2.13.16", "3.3.6"]
628}
629}]
630************************
631[success] Total time: 273 s (0:04:33.0), completed Dec 4, 2025, 3:43:18 PM
632[0JChecking patch project/plugins.sbt...
633Checking patch project/Dependencies.scala...
634Checking patch build.sbt...
635Applied patch project/plugins.sbt cleanly.
636Applied patch project/Dependencies.scala cleanly.
637Applied patch build.sbt cleanly.