Build Logs

akka/alpakka-kafka • 3.8.0-RC5:2025-12-31

Errors

6

Warnings

1305

Total Lines

1774

1##################################
2Clonning https://github.com/akka/alpakka-kafka.git into /build/repo using revision v4.0.2
3##################################
4Note: switching to '1e25e79f33e85703cfc3edd39eceaa3a3b5f471b'.
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.2.2
22----
23Preparing build for 3.8.0-RC5
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: build.sbt
34Pattern: val Scala3 = "3.2.2"
35Replacement: val Scala3 = "3.8.0-RC5"
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.2.2"' in build.sbt
40----
41Starting build for 3.8.0-RC5
42Execute tests: true
43sbt project found:
44Sbt version 1.8.2 is not supported, minimal supported version is 1.11.5
45Enforcing usage of sbt in version 1.11.5
46No prepare script found for project akka/alpakka-kafka
47##################################
48Scala version: 3.8.0-RC5
49Targets: com.typesafe.akka%akka-stream-kafka com.typesafe.akka%akka-stream-kafka-cluster-sharding com.typesafe.akka%akka-stream-kafka-testkit
50Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":[],"sourcePatches":[{"path":"build.sbt","pattern":"val Scala3 = \"3.2.2\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}
51##################################
52Using extra scalacOptions: ,REQUIRE:-source:3.8
53Filtering out scalacOptions: ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e
54[sbt_options] declare -a sbt_options=()
55[process_args] java_version = '17'
56[copyRt] java9_rt = '/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_17_0_8/rt.jar'
57# Executing command line:
58java
59-Dfile.encoding=UTF-8
60-Dcommunitybuild.scala=3.8.0-RC5
61-Dcommunitybuild.project.dependencies.add=
62-Xmx7G
63-Xms4G
64-Xss8M
65-Dsbt.script=/root/.sdkman/candidates/sbt/current/bin/sbt
66-Dscala.ext.dirs=/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_17_0_8
67-jar
68/root/.sdkman/candidates/sbt/1.11.5/bin/sbt-launch.jar
69"setCrossScalaVersions 3.8.0-RC5"
70"++3.8.0-RC5 -v"
71"mapScalacOptions ",REQUIRE:-source:3.8,-Wconf:msg=can be rewritten automatically under:s" ",-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e""
72"set every credentials := Nil"
73"excludeLibraryDependency com.github.ghik:zerowaste_{scalaVersion} com.olegpy:better-monadic-for_3 org.polyvariant:better-tostring_{scalaVersion} org.wartremover:wartremover_{scalaVersion}"
74"removeScalacOptionsStartingWith -P:wartremover"
75
76moduleMappings
77"runBuild 3.8.0-RC5 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":[],"sourcePatches":[{"path":"build.sbt","pattern":"val Scala3 = \"3.2.2\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}""" com.typesafe.akka%akka-stream-kafka com.typesafe.akka%akka-stream-kafka-cluster-sharding com.typesafe.akka%akka-stream-kafka-testkit"
78
79[info] welcome to sbt 1.11.5 (Eclipse Adoptium Java 17.0.8)
80[info] loading settings for project repo-build from akka.sbt, plugins.sbt...
81[info] loading project definition from /build/repo/project
82[info] compiling 5 Scala sources to /build/repo/project/target/scala-2.12/sbt-1.0/classes ...
83[info] Non-compiled module 'compiler-bridge_2.12' for Scala 2.12.20. Compiling...
84[info] Compilation completed in 8.089s.
85[info] done compiling
86/build/repo/build.sbt:271: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
87 .configs(IntegrationTest) // make CI not fail
88 ^
89/build/repo/build.sbt:278: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
90 .configs(IntegrationTest.extend(Test))
91 ^
92/build/repo/build.sbt:280: warning: lazy value itSettings in object Defaults is deprecated (since 1.9.0): Create a separate subproject instead of using IntegrationTest and in addition avoid using itSettings
93 .settings(Defaults.itSettings)
94 ^
95/build/repo/build.sbt:281: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
96 .settings(headerSettings(IntegrationTest))
97 ^
98/build/repo/build.sbt:313: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
99 IntegrationTest / parallelExecution := false
100 ^
101/build/repo/build.sbt:373: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
102 .configs(IntegrationTest)
103 ^
104/build/repo/build.sbt:375: warning: lazy value itSettings in object Defaults is deprecated (since 1.9.0): Create a separate subproject instead of using IntegrationTest and in addition avoid using itSettings
105 .settings(Defaults.itSettings)
106 ^
107/build/repo/build.sbt:376: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
108 .settings(headerSettings(IntegrationTest))
109 ^
110/build/repo/build.sbt:380: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
111 IntegrationTest / parallelExecution := false,
112 ^
113/build/repo/build.sbt:388: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
114 "org.testcontainers" % "kafka" % testcontainersVersion % IntegrationTest,
115 ^
116/build/repo/build.sbt:389: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
117 "com.typesafe.akka" %% "akka-slf4j" % akkaVersion % IntegrationTest,
118 ^
119/build/repo/build.sbt:390: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
120 "com.typesafe.akka" %% "akka-stream-testkit" % akkaVersion % IntegrationTest,
121 ^
122/build/repo/build.sbt:391: warning: value IntegrationTest in trait LibraryManagementSyntax is deprecated (since 1.9.0): Create a separate subproject for testing instead
123 "org.scalatest" %% "scalatest" % scalatestVersion % IntegrationTest
124 ^
125[info] loading settings for project alpakka-kafka from build.sbt...
126[info] resolving key references (10254 settings) ...
127[info]
128[info] ** Welcome to the Alpakka Kafka connector! **
129[info]
130[info] The build has three main modules:
131[info] core - the Kafka connector sources
132[info] clusterSharding - Akka Cluster External Sharding with Alpakka Kafka
133[info] tests - tests, Docker based integration tests, code for the documentation
134[info] testkit - framework for testing the connector
135[info]
136[info] Other modules:
137[info] docs - the sources for generating https://doc.akka.io/docs/alpakka-kafka/current
138[info] benchmarks - compare direct Kafka API usage with Alpakka Kafka
139[info]
140[info] Useful sbt tasks:
141[info]
142[info] docs/previewSite
143[info] builds Paradox and Scaladoc documentation, starts a webserver and
144[info] opens a new browser window
145[info]
146[info] verifyCodeStyle
147[info] checks if all of the code is formatted according to the configuration
148[info]
149[info] verifyDocs
150[info] builds all of the docs
151[info]
152[info] test
153[info] runs all the tests
154[info]
155[info] tests/IntegrationTest/test
156[info] run integration tests backed by Docker containers
157[info]
158[info] tests/testOnly -- -t "A consume-transform-produce cycle must complete in happy-path scenario"
159[info] run a single test with an exact name (use -z for partial match)
160[info]
161[info] benchmarks/IntegrationTest/testOnly *.AlpakkaKafkaPlainConsumer
162[info] run a single benchmark backed by Docker containers
163[info]
164[warn] there are 6 keys that are not used by any other settings/tasks:
165[warn]
166[warn] * alpakka-kafka / projectInfoVersion
167[warn] +- /build/repo/build.sbt:154
168[warn] * benchmarks / projectInfoVersion
169[warn] +- /build/repo/build.sbt:154
170[warn] * clusterSharding / projectInfoVersion
171[warn] +- /build/repo/build.sbt:154
172[warn] * core / projectInfoVersion
173[warn] +- /build/repo/build.sbt:154
174[warn] * testkit / projectInfoVersion
175[warn] +- /build/repo/build.sbt:154
176[warn] * tests / projectInfoVersion
177[warn] +- /build/repo/build.sbt:154
178[warn]
179[warn] note: a setting might still be used by a command; to exclude a key from this `lintUnused` check
180[warn] either append it to `Global / excludeLintKeys` or call .withRank(KeyRanks.Invisible) on the key
181Execute setCrossScalaVersions: 3.8.0-RC5
182OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in clusterSharding/crossScalaVersions
183OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in core/crossScalaVersions
184OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in testkit/crossScalaVersions
185[info]
186[info] ** Welcome to the Alpakka Kafka connector! **
187[info]
188[info] The build has three main modules:
189[info] core - the Kafka connector sources
190[info] clusterSharding - Akka Cluster External Sharding with Alpakka Kafka
191[info] tests - tests, Docker based integration tests, code for the documentation
192[info] testkit - framework for testing the connector
193[info]
194[info] Other modules:
195[info] docs - the sources for generating https://doc.akka.io/docs/alpakka-kafka/current
196[info] benchmarks - compare direct Kafka API usage with Alpakka Kafka
197[info]
198[info] Useful sbt tasks:
199[info]
200[info] docs/previewSite
201[info] builds Paradox and Scaladoc documentation, starts a webserver and
202[info] opens a new browser window
203[info]
204[info] verifyCodeStyle
205[info] checks if all of the code is formatted according to the configuration
206[info]
207[info] verifyDocs
208[info] builds all of the docs
209[info]
210[info] test
211[info] runs all the tests
212[info]
213[info] tests/IntegrationTest/test
214[info] run integration tests backed by Docker containers
215[info]
216[info] tests/testOnly -- -t "A consume-transform-produce cycle must complete in happy-path scenario"
217[info] run a single test with an exact name (use -z for partial match)
218[info]
219[info] benchmarks/IntegrationTest/testOnly *.AlpakkaKafkaPlainConsumer
220[info] run a single benchmark backed by Docker containers
221[info]
222[info] Setting Scala version to 3.8.0-RC5 on 3 projects.
223[info] Switching Scala version on:
224[info] clusterSharding (2.13.10, 2.12.17, 3.8.0-RC5)
225[info] core (2.13.10, 2.12.17, 3.8.0-RC5)
226[info] testkit (2.13.10, 2.12.17, 3.8.0-RC5)
227[info] Excluding projects:
228[info] benchmarks (2.13.10, 2.12.17)
229[info] docs (2.13.10, 2.12.17)
230[info] tests (2.13.10, 2.12.17)
231[info] * alpakka-kafka (2.13.10, 2.12.17)
232[info] Reapplying settings...
233[info]
234[info] ** Welcome to the Alpakka Kafka connector! **
235[info]
236[info] The build has three main modules:
237[info] core - the Kafka connector sources
238[info] clusterSharding - Akka Cluster External Sharding with Alpakka Kafka
239[info] tests - tests, Docker based integration tests, code for the documentation
240[info] testkit - framework for testing the connector
241[info]
242[info] Other modules:
243[info] docs - the sources for generating https://doc.akka.io/docs/alpakka-kafka/current
244[info] benchmarks - compare direct Kafka API usage with Alpakka Kafka
245[info]
246[info] Useful sbt tasks:
247[info]
248[info] docs/previewSite
249[info] builds Paradox and Scaladoc documentation, starts a webserver and
250[info] opens a new browser window
251[info]
252[info] verifyCodeStyle
253[info] checks if all of the code is formatted according to the configuration
254[info]
255[info] verifyDocs
256[info] builds all of the docs
257[info]
258[info] test
259[info] runs all the tests
260[info]
261[info] tests/IntegrationTest/test
262[info] run integration tests backed by Docker containers
263[info]
264[info] tests/testOnly -- -t "A consume-transform-produce cycle must complete in happy-path scenario"
265[info] run a single test with an exact name (use -z for partial match)
266[info]
267[info] benchmarks/IntegrationTest/testOnly *.AlpakkaKafkaPlainConsumer
268[info] run a single benchmark backed by Docker containers
269[info]
270Execute mapScalacOptions: ,REQUIRE:-source:3.8,-Wconf:msg=can be rewritten automatically under:s ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e
271[info] Reapplying settings...
272[info]
273[info] ** Welcome to the Alpakka Kafka connector! **
274[info]
275[info] The build has three main modules:
276[info] core - the Kafka connector sources
277[info] clusterSharding - Akka Cluster External Sharding with Alpakka Kafka
278[info] tests - tests, Docker based integration tests, code for the documentation
279[info] testkit - framework for testing the connector
280[info]
281[info] Other modules:
282[info] docs - the sources for generating https://doc.akka.io/docs/alpakka-kafka/current
283[info] benchmarks - compare direct Kafka API usage with Alpakka Kafka
284[info]
285[info] Useful sbt tasks:
286[info]
287[info] docs/previewSite
288[info] builds Paradox and Scaladoc documentation, starts a webserver and
289[info] opens a new browser window
290[info]
291[info] verifyCodeStyle
292[info] checks if all of the code is formatted according to the configuration
293[info]
294[info] verifyDocs
295[info] builds all of the docs
296[info]
297[info] test
298[info] runs all the tests
299[info]
300[info] tests/IntegrationTest/test
301[info] run integration tests backed by Docker containers
302[info]
303[info] tests/testOnly -- -t "A consume-transform-produce cycle must complete in happy-path scenario"
304[info] run a single test with an exact name (use -z for partial match)
305[info]
306[info] benchmarks/IntegrationTest/testOnly *.AlpakkaKafkaPlainConsumer
307[info] run a single benchmark backed by Docker containers
308[info]
309[info] Defining Global / credentials, benchmarks / credentials and 5 others.
310[info] The new values will be used by Global / pgpSelectPassphrase, Global / pgpSigningKey and 34 others.
311[info] Run `last` for details.
312[info] Reapplying settings...
313[info]
314[info] ** Welcome to the Alpakka Kafka connector! **
315[info]
316[info] The build has three main modules:
317[info] core - the Kafka connector sources
318[info] clusterSharding - Akka Cluster External Sharding with Alpakka Kafka
319[info] tests - tests, Docker based integration tests, code for the documentation
320[info] testkit - framework for testing the connector
321[info]
322[info] Other modules:
323[info] docs - the sources for generating https://doc.akka.io/docs/alpakka-kafka/current
324[info] benchmarks - compare direct Kafka API usage with Alpakka Kafka
325[info]
326[info] Useful sbt tasks:
327[info]
328[info] docs/previewSite
329[info] builds Paradox and Scaladoc documentation, starts a webserver and
330[info] opens a new browser window
331[info]
332[info] verifyCodeStyle
333[info] checks if all of the code is formatted according to the configuration
334[info]
335[info] verifyDocs
336[info] builds all of the docs
337[info]
338[info] test
339[info] runs all the tests
340[info]
341[info] tests/IntegrationTest/test
342[info] run integration tests backed by Docker containers
343[info]
344[info] tests/testOnly -- -t "A consume-transform-produce cycle must complete in happy-path scenario"
345[info] run a single test with an exact name (use -z for partial match)
346[info]
347[info] benchmarks/IntegrationTest/testOnly *.AlpakkaKafkaPlainConsumer
348[info] run a single benchmark backed by Docker containers
349[info]
350Execute excludeLibraryDependency: com.github.ghik:zerowaste_{scalaVersion} com.olegpy:better-monadic-for_3 org.polyvariant:better-tostring_{scalaVersion} org.wartremover:wartremover_{scalaVersion}
351[info] Reapplying settings...
352OpenCB::Failed to reapply settings in excludeLibraryDependency: Reference to undefined setting:
353
354 Global / allExcludeDependencies from Global / allExcludeDependencies (CommunityBuildPlugin.scala:331)
355 Did you mean clusterSharding / allExcludeDependencies ?
356 , retry without global scopes
357[info] Reapplying settings...
358[info]
359[info] ** Welcome to the Alpakka Kafka connector! **
360[info]
361[info] The build has three main modules:
362[info] core - the Kafka connector sources
363[info] clusterSharding - Akka Cluster External Sharding with Alpakka Kafka
364[info] tests - tests, Docker based integration tests, code for the documentation
365[info] testkit - framework for testing the connector
366[info]
367[info] Other modules:
368[info] docs - the sources for generating https://doc.akka.io/docs/alpakka-kafka/current
369[info] benchmarks - compare direct Kafka API usage with Alpakka Kafka
370[info]
371[info] Useful sbt tasks:
372[info]
373[info] docs/previewSite
374[info] builds Paradox and Scaladoc documentation, starts a webserver and
375[info] opens a new browser window
376[info]
377[info] verifyCodeStyle
378[info] checks if all of the code is formatted according to the configuration
379[info]
380[info] verifyDocs
381[info] builds all of the docs
382[info]
383[info] test
384[info] runs all the tests
385[info]
386[info] tests/IntegrationTest/test
387[info] run integration tests backed by Docker containers
388[info]
389[info] tests/testOnly -- -t "A consume-transform-produce cycle must complete in happy-path scenario"
390[info] run a single test with an exact name (use -z for partial match)
391[info]
392[info] benchmarks/IntegrationTest/testOnly *.AlpakkaKafkaPlainConsumer
393[info] run a single benchmark backed by Docker containers
394[info]
395Execute removeScalacOptionsStartingWith: -P:wartremover
396[info] Reapplying settings...
397[info]
398[info] ** Welcome to the Alpakka Kafka connector! **
399[info]
400[info] The build has three main modules:
401[info] core - the Kafka connector sources
402[info] clusterSharding - Akka Cluster External Sharding with Alpakka Kafka
403[info] tests - tests, Docker based integration tests, code for the documentation
404[info] testkit - framework for testing the connector
405[info]
406[info] Other modules:
407[info] docs - the sources for generating https://doc.akka.io/docs/alpakka-kafka/current
408[info] benchmarks - compare direct Kafka API usage with Alpakka Kafka
409[info]
410[info] Useful sbt tasks:
411[info]
412[info] docs/previewSite
413[info] builds Paradox and Scaladoc documentation, starts a webserver and
414[info] opens a new browser window
415[info]
416[info] verifyCodeStyle
417[info] checks if all of the code is formatted according to the configuration
418[info]
419[info] verifyDocs
420[info] builds all of the docs
421[info]
422[info] test
423[info] runs all the tests
424[info]
425[info] tests/IntegrationTest/test
426[info] run integration tests backed by Docker containers
427[info]
428[info] tests/testOnly -- -t "A consume-transform-produce cycle must complete in happy-path scenario"
429[info] run a single test with an exact name (use -z for partial match)
430[info]
431[info] benchmarks/IntegrationTest/testOnly *.AlpakkaKafkaPlainConsumer
432[info] run a single benchmark backed by Docker containers
433[info]
434[success] Total time: 0 s, completed Dec 31, 2025, 9:10:51 PM
435Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":[],"sourcePatches":[{"path":"build.sbt","pattern":"val Scala3 = \"3.2.2\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}
436Parsed config: Success(ProjectBuildConfig(ProjectsConfig(List(),Map()),Full,List()))
437Starting build...
438Projects: Set(core, clusterSharding, testkit)
439Starting build for ProjectRef(file:/build/repo/,core) (akka-stream-kafka)... [0/3]
440OpenCB::Exclude Scala3 specific scalacOption `REQUIRE:-source:3.8` in Scala 2.12.20 module Global
441Compile scalacOptions: -encoding, UTF-8, --java-output-version:17, 8, -Wconf:cat=feature:w,cat=deprecation&msg=.*JavaConverters.*:s,cat=unchecked:w,cat=lint:w,cat=unused:w,cat=w-flag:w, -Wconf:msg=can be rewritten automatically under:s, -source:3.8
442[info] compiling 58 Scala sources to /build/repo/core/target/scala-3.8.0-RC5/classes ...
443[warn] Failed to parse `-Wconf` configuration: cat=feature:w,cat=deprecation&msg=.*JavaConverters.*:s,cat=unchecked:w,cat=lint:w,cat=unused:w,cat=w-flag:w,msg=can be rewritten automatically under:s
444[warn] unknown category: w-flag
445[warn] unknown category: unused
446[warn] unknown category: lint
447[warn] Note: for multiple filters, use `-Wconf:filter1:action1,filter2:action2`
448[warn] or alternatively `-Wconf:filter1:action1 -Wconf:filter2:action2`
449[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/ConsumerSettings.scala:657:63
450[warn] 657 | enriched.map(consumerFactory)(ExecutionContext.fromExecutor(executor)).toJava
451[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
452[warn] |Implicit parameters should be provided with a `using` clause.
453[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
454[warn] |To disable the warning, please use the following option:
455[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
456[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/ProducerSettings.scala:488:60
457[warn] 488 | createKafkaProducerAsync()(ExecutionContext.fromExecutor(executor)).toJava
458[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
459[warn] |Implicit parameters should be provided with a `using` clause.
460[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
461[warn] |To disable the warning, please use the following option:
462[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
463[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/RestrictedConsumer.scala:17:50
464[warn] 17 |final class RestrictedConsumer(consumer: Consumer[_, _], duration: java.time.Duration) {
465[warn] | ^
466[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
467[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
468[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/RestrictedConsumer.scala:17:53
469[warn] 17 |final class RestrictedConsumer(consumer: Consumer[_, _], duration: java.time.Duration) {
470[warn] | ^
471[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
472[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
473[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/BaseSingleSourceLogic.scala:37:48
474[warn] 37 | protected final var consumerActor: ActorRef = _
475[warn] | ^
476[warn] |`= _` has been deprecated; use `= uninitialized` instead.
477[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
478[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
479[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/BaseSingleSourceLogic.scala:38:42
480[warn] 38 | protected var sourceActor: StageActor = _
481[warn] | ^
482[warn] |`= _` has been deprecated; use `= uninitialized` instead.
483[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
484[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
485[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommitCollectorStage.scala:52:42
486[warn] 52 | override protected def logSource: Class[_] = classOf[CommitCollectorStageLogic]
487[warn] | ^
488[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
489[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
490[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittableSources.scala:38:94
491[warn] 38 | override protected def logic(shape: SourceShape[CommittableMessage[K, V]]): GraphStageLogic with Control =
492[warn] | ^^^^
493[warn] |with as a type operator has been deprecated; use & instead
494[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
495[warn] |
496[warn] | longer explanation available when compiling with `-explain`
497[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittableSources.scala:61:21
498[warn] 61 | ): GraphStageLogic with Control =
499[warn] | ^^^^
500[warn] |with as a type operator has been deprecated; use & instead
501[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
502[warn] |
503[warn] | longer explanation available when compiling with `-explain`
504[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittableSources.scala:82:94
505[warn] 82 | override protected def logic(shape: SourceShape[CommittableMessage[K, V]]): GraphStageLogic with Control =
506[warn] | ^^^^
507[warn] |with as a type operator has been deprecated; use & instead
508[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
509[warn] |
510[warn] | longer explanation available when compiling with `-explain`
511[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittableSources.scala:107:21
512[warn] 107 | ): GraphStageLogic with Control = {
513[warn] | ^^^^
514[warn] |with as a type operator has been deprecated; use & instead
515[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
516[warn] |
517[warn] | longer explanation available when compiling with `-explain`
518[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittableSources.scala:154:66
519[warn] 154 | Future.sequence(futures).map(_ => Done)(ExecutionContexts.parasitic)
520[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
521[warn] |Implicit parameters should be provided with a `using` clause.
522[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
523[warn] |To disable the warning, please use the following option:
524[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
525[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittableSources.scala:212:23
526[warn] 212 | .ask(msg)(Timeout(commitTimeout))
527[warn] | ^^^^^^^^^^^^^^^^^^^^^^
528[warn] |Implicit parameters should be provided with a `using` clause.
529[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
530[warn] |To disable the warning, please use the following option:
531[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
532[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittableSources.scala:213:40
533[warn] 213 | .map(_ => Done)(ExecutionContexts.parasitic)
534[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
535[warn] |Implicit parameters should be provided with a `using` clause.
536[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
537[warn] |To disable the warning, please use the following option:
538[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
539[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittableSources.scala:218:8
540[warn] 218 | }(ec)
541[warn] | ^^
542[warn] |Implicit parameters should be provided with a `using` clause.
543[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
544[warn] |To disable the warning, please use the following option:
545[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
546[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittingProducerSinkStage.scala:64:42
547[warn] 64 | override protected def logSource: Class[_] = classOf[CommittingProducerSinkStage[_, _, _]]
548[warn] | ^
549[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
550[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
551[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittingProducerSinkStage.scala:64:83
552[warn] 64 | override protected def logSource: Class[_] = classOf[CommittingProducerSinkStage[_, _, _]]
553[warn] | ^
554[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
555[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
556[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittingProducerSinkStage.scala:64:86
557[warn] 64 | override protected def logSource: Class[_] = classOf[CommittingProducerSinkStage[_, _, _]]
558[warn] | ^
559[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
560[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
561[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittingProducerSinkStage.scala:64:89
562[warn] 64 | override protected def logSource: Class[_] = classOf[CommittingProducerSinkStage[_, _, _]]
563[warn] | ^
564[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
565[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
566[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/CommittingProducerSinkStage.scala:186:77
567[warn] 186 | .onComplete(t => commitResultCB.invoke(batchSize -> t))(materializer.executionContext)
568[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
569[warn] |Implicit parameters should be provided with a `using` clause.
570[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
571[warn] |To disable the warning, please use the following option:
572[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
573[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ConsumerProgressTracking.scala:44:50
574[warn] 44 | consumer: Consumer[_, _],
575[warn] | ^
576[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
577[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
578[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ConsumerProgressTracking.scala:44:53
579[warn] 44 | consumer: Consumer[_, _],
580[warn] | ^
581[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
582[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
583[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ConsumerProgressTracking.scala:132:59
584[warn] 132 | consumer: Consumer[_, _],
585[warn] | ^
586[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
587[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
588[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ConsumerProgressTracking.scala:132:62
589[warn] 132 | consumer: Consumer[_, _],
590[warn] | ^
591[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
592[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
593[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ControlImplementations.scala:35:25
594[warn] 35 | def shape: SourceShape[_]
595[warn] | ^
596[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
597[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
598[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ControlImplementations.scala:87:38
599[warn] 87 | .ask(RequestMetrics)(Timeout(1.minute))
600[warn] | ^^^^^^^^^^^^^^^^^
601[warn] |Implicit parameters should be provided with a `using` clause.
602[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
603[warn] |To disable the warning, please use the following option:
604[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
605[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ControlImplementations.scala:89:44
606[warn] 89 | .map(_.metrics)(ExecutionContexts.parasitic)
607[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
608[warn] |Implicit parameters should be provided with a `using` clause.
609[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
610[warn] |To disable the warning, please use the following option:
611[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
612[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ControlImplementations.scala:90:8
613[warn] 90 | }(executionContext)
614[warn] | ^^^^^^^^^^^^^^^^
615[warn] |Implicit parameters should be provided with a `using` clause.
616[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
617[warn] |To disable the warning, please use the following option:
618[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
619[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ControlImplementations.scala:103:87
620[warn] 103 | underlying.drainAndShutdown(streamCompletion.toScala)(ExecutionContext.fromExecutor(ec)).toJava
621[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
622[warn] |Implicit parameters should be provided with a `using` clause.
623[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
624[warn] |To disable the warning, please use the following option:
625[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
626[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ControlImplementations.scala:108:55
627[warn] 108 | underlying.metrics.map(_.asJava)(ExecutionContexts.parasitic).toJava
628[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
629[warn] |Implicit parameters should be provided with a `using` clause.
630[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
631[warn] |To disable the warning, please use the following option:
632[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
633[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DefaultProducerStage.scala:53:42
634[warn] 53 | override protected def logSource: Class[_] = classOf[DefaultProducerStage[_, _, _, _, _]]
635[warn] | ^
636[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
637[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
638[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DefaultProducerStage.scala:53:76
639[warn] 53 | override protected def logSource: Class[_] = classOf[DefaultProducerStage[_, _, _, _, _]]
640[warn] | ^
641[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
642[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
643[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DefaultProducerStage.scala:53:79
644[warn] 53 | override protected def logSource: Class[_] = classOf[DefaultProducerStage[_, _, _, _, _]]
645[warn] | ^
646[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
647[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
648[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DefaultProducerStage.scala:53:82
649[warn] 53 | override protected def logSource: Class[_] = classOf[DefaultProducerStage[_, _, _, _, _]]
650[warn] | ^
651[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
652[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
653[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DefaultProducerStage.scala:53:85
654[warn] 53 | override protected def logSource: Class[_] = classOf[DefaultProducerStage[_, _, _, _, _]]
655[warn] | ^
656[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
657[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
658[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DefaultProducerStage.scala:53:88
659[warn] 53 | override protected def logSource: Class[_] = classOf[DefaultProducerStage[_, _, _, _, _]]
660[warn] | ^
661[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
662[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
663[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DefaultProducerStage.scala:172:55
664[warn] 172 | private abstract class CallbackBase(promise: Promise[_]) extends Callback {
665[warn] | ^
666[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
667[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
668[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DeferredProducer.scala:47:43
669[warn] 47 | protected var producer: Producer[K, V] = _
670[warn] | ^
671[warn] |`= _` has been deprecated; use `= uninitialized` instead.
672[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
673[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
674[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DeferredProducer.scala:61:74
675[warn] 61 | val producerFuture = settings.createKafkaProducerAsync()(materializer.executionContext)
676[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
677[warn] |Implicit parameters should be provided with a `using` clause.
678[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
679[warn] |To disable the warning, please use the following option:
680[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
681[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/DeferredProducer.scala:75:30
682[warn] 75 | )(ExecutionContexts.parasitic)
683[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
684[warn] |Implicit parameters should be provided with a `using` clause.
685[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
686[warn] |To disable the warning, please use the following option:
687[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
688[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/ExternalSingleSourceLogic.scala:26:48
689[warn] 26 | final override protected def logSource: Class[_] = classOf[ExternalSingleSourceLogic[K, V, Msg]]
690[warn] | ^
691[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
692[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
693[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:189:49
694[warn] 189 | private var settings: ConsumerSettings[K, V] = _
695[warn] | ^
696[warn] |`= _` has been deprecated; use `= uninitialized` instead.
697[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
698[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
699[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:190:48
700[warn] 190 | private var pollTimeout: java.time.Duration = _
701[warn] | ^
702[warn] |`= _` has been deprecated; use `= uninitialized` instead.
703[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
704[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
705[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:193:58
706[warn] 193 | private var offsetForTimesTimeout: java.time.Duration = _
707[warn] | ^
708[warn] |`= _` has been deprecated; use `= uninitialized` instead.
709[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
710[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
711[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:196:52
712[warn] 196 | private var positionTimeout: java.time.Duration = _
713[warn] | ^
714[warn] |`= _` has been deprecated; use `= uninitialized` instead.
715[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
716[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
717[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:202:41
718[warn] 202 | private var consumer: Consumer[K, V] = _
719[warn] | ^
720[warn] |`= _` has been deprecated; use `= uninitialized` instead.
721[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
722[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
723[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:204:51
724[warn] 204 | private var commitRefreshing: CommitRefreshing = _
725[warn] | ^
726[warn] |`= _` has been deprecated; use `= uninitialized` instead.
727[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
728[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
729[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:205:57
730[warn] 205 | private var resetProtection: ConsumerResetProtection = _
731[warn] | ^
732[warn] |`= _` has been deprecated; use `= uninitialized` instead.
733[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
734[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
735[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:287:69
736[warn] 287 | val unmodifiableYetMutableMetrics: java.util.Map[MetricName, _ <: Metric] = consumer.metrics()
737[warn] | ^
738[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
739[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
740[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:477:34
741[warn] 477 | private def receivePoll(p: Poll[_, _]): Unit =
742[warn] | ^
743[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
744[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
745[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaConsumerActor.scala:477:37
746[warn] 477 | private def receivePoll(p: Poll[_, _]): Unit =
747[warn] | ^
748[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
749[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
750[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/KafkaSourceStage.scala:24:64
751[warn] 24 | protected def logic(shape: SourceShape[Msg]): GraphStageLogic with Control
752[warn] | ^^^^
753[warn] |with as a type operator has been deprecated; use & instead
754[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
755[warn] |
756[warn] | longer explanation available when compiling with `-explain`
757[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/LoggingWithId.scala:24:9
758[warn] 24 | private[this] var _log: LoggingAdapter = _
759[warn] | ^^^^^^
760[warn] |Ignoring [this] qualifier.
761[warn] |The syntax `private[this]` will be deprecated in the future; just write `private` instead.
762[warn] |See: https://docs.scala-lang.org/scala3/reference/dropped-features/this-qualifier.html
763[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
764[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/LoggingWithId.scala:24:43
765[warn] 24 | private[this] var _log: LoggingAdapter = _
766[warn] | ^
767[warn] |`= _` has been deprecated; use `= uninitialized` instead.
768[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
769[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
770[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/LoggingWithId.scala:38:9
771[warn] 38 | private[this] var _log: LoggingAdapter = _
772[warn] | ^^^^^^
773[warn] |Ignoring [this] qualifier.
774[warn] |The syntax `private[this]` will be deprecated in the future; just write `private` instead.
775[warn] |See: https://docs.scala-lang.org/scala3/reference/dropped-features/this-qualifier.html
776[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
777[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/LoggingWithId.scala:38:43
778[warn] 38 | private[this] var _log: LoggingAdapter = _
779[warn] | ^
780[warn] |`= _` has been deprecated; use `= uninitialized` instead.
781[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
782[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
783[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/MessageBuilder.scala:112:43
784[warn] 112 | val NoMetadataFromRecord: ConsumerRecord[_, _] => String = (_: ConsumerRecord[_, _]) =>
785[warn] | ^
786[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
787[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
788[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/MessageBuilder.scala:112:46
789[warn] 112 | val NoMetadataFromRecord: ConsumerRecord[_, _] => String = (_: ConsumerRecord[_, _]) =>
790[warn] | ^
791[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
792[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
793[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/MessageBuilder.scala:112:80
794[warn] 112 | val NoMetadataFromRecord: ConsumerRecord[_, _] => String = (_: ConsumerRecord[_, _]) =>
795[warn] | ^
796[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
797[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
798[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/MessageBuilder.scala:112:83
799[warn] 112 | val NoMetadataFromRecord: ConsumerRecord[_, _] => String = (_: ConsumerRecord[_, _]) =>
800[warn] | ^
801[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
802[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
803[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/PlainSources.scala:26:90
804[warn] 26 | override protected def logic(shape: SourceShape[ConsumerRecord[K, V]]): GraphStageLogic with Control =
805[warn] | ^^^^
806[warn] |with as a type operator has been deprecated; use & instead
807[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
808[warn] |
809[warn] | longer explanation available when compiling with `-explain`
810[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/PlainSources.scala:36:90
811[warn] 36 | override protected def logic(shape: SourceShape[ConsumerRecord[K, V]]): GraphStageLogic with Control =
812[warn] | ^^^^
813[warn] |with as a type operator has been deprecated; use & instead
814[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
815[warn] |
816[warn] | longer explanation available when compiling with `-explain`
817[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/PlainSources.scala:56:21
818[warn] 56 | ): GraphStageLogic with Control = {
819[warn] | ^^^^
820[warn] |with as a type operator has been deprecated; use & instead
821[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
822[warn] |
823[warn] | longer explanation available when compiling with `-explain`
824[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/SingleSourceLogic.scala:29:42
825[warn] 29 | override protected def logSource: Class[_] = classOf[SingleSourceLogic[K, V, Msg]]
826[warn] | ^
827[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
828[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
829[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/SourceLogicBuffer.scala:23:24
830[warn] 23 | self: GraphStageLogic with StageIdLogging =>
831[warn] | ^^^^
832[warn] |with as a type operator has been deprecated; use & instead
833[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
834[warn] |
835[warn] | longer explanation available when compiling with `-explain`
836[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/SubSourceLogic.scala:65:42
837[warn] 65 | protected var consumerActor: ActorRef = _
838[warn] | ^
839[warn] |`= _` has been deprecated; use `= uninitialized` instead.
840[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
841[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
842[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/SubSourceLogic.scala:66:42
843[warn] 66 | protected var sourceActor: StageActor = _
844[warn] | ^
845[warn] |`= _` has been deprecated; use `= uninitialized` instead.
846[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
847[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
848[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/SubSourceLogic.scala:416:45
849[warn] 416 | protected var subSourceActor: StageActor = _
850[warn] | ^
851[warn] |`= _` has been deprecated; use `= uninitialized` instead.
852[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
853[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
854[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/SubSourceLogic.scala:158:61
855[warn] 158 | .ask(KafkaConsumerActor.Internal.Seek(offsets))(Timeout(10.seconds), sourceActor.ref)
856[warn] | ^^^^^^^^^^^^^^^^^^^
857[warn] |Implicit parameters should be provided with a `using` clause.
858[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
859[warn] |To disable the warning, please use the following option:
860[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
861[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalProducerStage.scala:119:42
862[warn] 119 | override protected def logSource: Class[_] = classOf[TransactionalProducerStage[_, _, _]]
863[warn] | ^
864[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
865[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
866[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalProducerStage.scala:119:82
867[warn] 119 | override protected def logSource: Class[_] = classOf[TransactionalProducerStage[_, _, _]]
868[warn] | ^
869[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
870[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
871[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalProducerStage.scala:119:85
872[warn] 119 | override protected def logSource: Class[_] = classOf[TransactionalProducerStage[_, _, _]]
873[warn] | ^
874[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
875[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
876[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalProducerStage.scala:119:88
877[warn] 119 | override protected def logSource: Class[_] = classOf[TransactionalProducerStage[_, _, _]]
878[warn] | ^
879[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
880[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
881[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalProducerStage.scala:255:21
882[warn] 255 | }(materializer.executionContext)
883[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
884[warn] |Implicit parameters should be provided with a `using` clause.
885[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
886[warn] |To disable the warning, please use the following option:
887[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
888[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:41:96
889[warn] 41 | override protected def logic(shape: SourceShape[TransactionalMessage[K, V]]): GraphStageLogic with Control =
890[warn] | ^^^^
891[warn] |with as a type operator has been deprecated; use & instead
892[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
893[warn] |
894[warn] | longer explanation available when compiling with `-explain`
895[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:78:21
896[warn] 78 | ): GraphStageLogic with Control =
897[warn] | ^^^^
898[warn] |with as a type operator has been deprecated; use & instead
899[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
900[warn] |
901[warn] | longer explanation available when compiling with `-explain`
902[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:95:42
903[warn] 95 | override protected def logSource: Class[_] = classOf[TransactionalSourceLogic[_, _, _]]
904[warn] | ^
905[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
906[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
907[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:95:80
908[warn] 95 | override protected def logSource: Class[_] = classOf[TransactionalSourceLogic[_, _, _]]
909[warn] | ^
910[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
911[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
912[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:95:83
913[warn] 95 | override protected def logSource: Class[_] = classOf[TransactionalSourceLogic[_, _, _]]
914[warn] | ^
915[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
916[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
917[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:95:86
918[warn] 95 | override protected def logSource: Class[_] = classOf[TransactionalSourceLogic[_, _, _]]
919[warn] | ^
920[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
921[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
922[warn] -- [E003] Syntax Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:219:21
923[warn] 219 | ): GraphStageLogic with Control = {
924[warn] | ^^^^
925[warn] |with as a type operator has been deprecated; use & instead
926[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
927[warn] |
928[warn] | longer explanation available when compiling with `-explain`
929[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:142:72
930[warn] 142 | CommittedMarkerRef(sourceActor.ref, consumerSettings.commitTimeout)(ec)
931[warn] | ^^
932[warn] |Implicit parameters should be provided with a `using` clause.
933[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
934[warn] |To disable the warning, please use the following option:
935[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
936[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:302:40
937[warn] 302 | .ask(Committed(offsets))(Timeout(commitTimeout))
938[warn] | ^^^^^^^^^^^^^^^^^^^^^^
939[warn] |Implicit parameters should be provided with a `using` clause.
940[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
941[warn] |To disable the warning, please use the following option:
942[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
943[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/internal/TransactionalSources.scala:438:75
944[warn] 438 | CommittedMarkerRef(subSourceActor.ref, consumerSettings.commitTimeout)(ec)
945[warn] | ^^
946[warn] |Implicit parameters should be provided with a `using` clause.
947[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
948[warn] |To disable the warning, please use the following option:
949[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
950[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/Consumer.scala:283:88
951[warn] 283 | getOffsetsOnAssign(tps.asJava).toScala.map(_.asScala.toMap)(ExecutionContexts.parasitic),
952[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
953[warn] |Implicit parameters should be provided with a `using` clause.
954[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
955[warn] |To disable the warning, please use the following option:
956[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
957[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/Consumer.scala:314:88
958[warn] 314 | getOffsetsOnAssign(tps.asJava).toScala.map(_.asScala.toMap)(ExecutionContexts.parasitic),
959[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
960[warn] |Implicit parameters should be provided with a `using` clause.
961[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
962[warn] |To disable the warning, please use the following option:
963[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
964[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/Consumer.scala:353:88
965[warn] 353 | getOffsetsOnAssign(tps.asJava).toScala.map(_.asScala.toMap)(ExecutionContexts.parasitic),
966[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
967[warn] |Implicit parameters should be provided with a `using` clause.
968[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
969[warn] |To disable the warning, please use the following option:
970[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
971[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/Consumer.scala:378:88
972[warn] 378 | getOffsetsOnAssign(tps.asJava).toScala.map(_.asScala.toMap)(ExecutionContexts.parasitic),
973[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
974[warn] |Implicit parameters should be provided with a `using` clause.
975[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
976[warn] |To disable the warning, please use the following option:
977[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
978[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/MetadataClient.scala:30:26
979[warn] 30 | }(ExecutionContexts.parasitic)
980[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
981[warn] |Implicit parameters should be provided with a `using` clause.
982[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
983[warn] |To disable the warning, please use the following option:
984[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
985[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/MetadataClient.scala:36:39
986[warn] 36 | .map(Long.box)(ExecutionContexts.parasitic)
987[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
988[warn] |Implicit parameters should be provided with a `using` clause.
989[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
990[warn] |To disable the warning, please use the following option:
991[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
992[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/MetadataClient.scala:46:26
993[warn] 46 | }(ExecutionContexts.parasitic)
994[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
995[warn] |Implicit parameters should be provided with a `using` clause.
996[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
997[warn] |To disable the warning, please use the following option:
998[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
999[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/MetadataClient.scala:52:39
1000[warn] 52 | .map(Long.box)(ExecutionContexts.parasitic)
1001[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1002[warn] |Implicit parameters should be provided with a `using` clause.
1003[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1004[warn] |To disable the warning, please use the following option:
1005[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1006[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/MetadataClient.scala:60:26
1007[warn] 60 | }(ExecutionContexts.parasitic)
1008[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1009[warn] |Implicit parameters should be provided with a `using` clause.
1010[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1011[warn] |To disable the warning, please use the following option:
1012[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1013[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/MetadataClient.scala:68:26
1014[warn] 68 | }(ExecutionContexts.parasitic)
1015[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1016[warn] |Implicit parameters should be provided with a `using` clause.
1017[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1018[warn] |To disable the warning, please use the following option:
1019[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1020[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/MetadataClient.scala:84:26
1021[warn] 84 | }(ExecutionContexts.parasitic)
1022[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1023[warn] |Implicit parameters should be provided with a `using` clause.
1024[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1025[warn] |To disable the warning, please use the following option:
1026[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1027[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/MetadataClient.scala:104:41
1028[warn] 104 | .create(consumerSettings, timeout)(system, ExecutionContexts.fromExecutor(executor))
1029[warn] | ^^^^^^
1030[warn] |Implicit parameters should be provided with a `using` clause.
1031[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1032[warn] |To disable the warning, please use the following option:
1033[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1034[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/Producer.scala:152:66
1035[warn] 152 | def committableSinkWithOffsetContext[K, V, IN <: Envelope[K, V, _], C <: Committable](
1036[warn] | ^
1037[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1038[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1039[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/SendProducer.scala:26:41
1040[warn] 26 | this(scaladsl.SendProducer(settings)(system))
1041[warn] | ^^^^^^
1042[warn] |Implicit parameters should be provided with a `using` clause.
1043[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1044[warn] |To disable the warning, please use the following option:
1045[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1046[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/javadsl/SendProducer.scala:35:48
1047[warn] 35 | this(scaladsl.SendProducer(settings)(system.classicSystem))
1048[warn] | ^^^^^^^^^^^^^^^^^^^^
1049[warn] |Implicit parameters should be provided with a `using` clause.
1050[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1051[warn] |To disable the warning, please use the following option:
1052[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1053[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/Committer.scala:40:69
1054[warn] 40 | batch.commitInternal().map(_ => batch)(ExecutionContexts.parasitic)
1055[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1056[warn] |Implicit parameters should be provided with a `using` clause.
1057[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1058[warn] |To disable the warning, please use the following option:
1059[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1060[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/Consumer.scala:107:58
1061[warn] 107 | .flatMap(_ => streamCompletion)(ExecutionContexts.parasitic)
1062[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1063[warn] |Implicit parameters should be provided with a `using` clause.
1064[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1065[warn] |To disable the warning, please use the following option:
1066[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1067[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/Consumer.scala:108:42
1068[warn] 108 | .map(_ => Done)(ExecutionContexts.parasitic)
1069[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1070[warn] |Implicit parameters should be provided with a `using` clause.
1071[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1072[warn] |To disable the warning, please use the following option:
1073[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1074[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/Consumer.scala:118:114
1075[warn] 118 | def drainAndShutdown()(implicit ec: ExecutionContext): Future[T] = control.drainAndShutdown(streamCompletion)(ec)
1076[warn] | ^^
1077[warn] |Implicit parameters should be provided with a `using` clause.
1078[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1079[warn] |To disable the warning, please use the following option:
1080[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1081[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/Consumer.scala:122:58
1082[warn] 122 | .flatMap(_ => streamCompletion)(ExecutionContexts.parasitic)
1083[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1084[warn] |Implicit parameters should be provided with a `using` clause.
1085[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1086[warn] |To disable the warning, please use the following option:
1087[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1088[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/Consumer.scala:123:42
1089[warn] 123 | .map(_ => Done)(ExecutionContexts.parasitic)
1090[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1091[warn] |Implicit parameters should be provided with a `using` clause.
1092[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1093[warn] |To disable the warning, please use the following option:
1094[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1095[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/Consumer.scala:260:80
1096[warn] 260 | m.committableOffset.commitInternal().map(_ => m.record)(ExecutionContexts.parasitic)
1097[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1098[warn] |Implicit parameters should be provided with a `using` clause.
1099[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1100[warn] |To disable the warning, please use the following option:
1101[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1102[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/DiscoverySupport.scala:81:31
1103[warn] 81 | bootstrapServers(config)(sys)
1104[warn] | ^^^
1105[warn] |Implicit parameters should be provided with a `using` clause.
1106[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1107[warn] |To disable the warning, please use the following option:
1108[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1109[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/DiscoverySupport.scala:105:31
1110[warn] 105 | bootstrapServers(config)(sys)
1111[warn] | ^^^
1112[warn] |Implicit parameters should be provided with a `using` clause.
1113[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1114[warn] |To disable the warning, please use the following option:
1115[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1116[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:27:54
1117[warn] 27 | (consumerActor ? GetBeginningOffsets(partitions))(timeout)
1118[warn] | ^^^^^^^
1119[warn] |Implicit parameters should be provided with a `using` clause.
1120[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1121[warn] |To disable the warning, please use the following option:
1122[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1123[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:33:26
1124[warn] 33 | }(ExecutionContexts.parasitic)
1125[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1126[warn] |Implicit parameters should be provided with a `using` clause.
1127[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1128[warn] |To disable the warning, please use the following option:
1129[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1130[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:40:48
1131[warn] 40 | (consumerActor ? GetEndOffsets(partitions))(timeout)
1132[warn] | ^^^^^^^
1133[warn] |Implicit parameters should be provided with a `using` clause.
1134[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1135[warn] |To disable the warning, please use the following option:
1136[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1137[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:46:26
1138[warn] 46 | }(ExecutionContexts.parasitic)
1139[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1140[warn] |Implicit parameters should be provided with a `using` clause.
1141[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1142[warn] |To disable the warning, please use the following option:
1143[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1144[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:53:33
1145[warn] 53 | (consumerActor ? ListTopics)(timeout)
1146[warn] | ^^^^^^^
1147[warn] |Implicit parameters should be provided with a `using` clause.
1148[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1149[warn] |To disable the warning, please use the following option:
1150[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1151[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:59:26
1152[warn] 59 | }(ExecutionContexts.parasitic)
1153[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1154[warn] |Implicit parameters should be provided with a `using` clause.
1155[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1156[warn] |To disable the warning, please use the following option:
1157[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1158[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:62:46
1159[warn] 62 | (consumerActor ? GetPartitionsFor(topic))(timeout)
1160[warn] | ^^^^^^^
1161[warn] |Implicit parameters should be provided with a `using` clause.
1162[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1163[warn] |To disable the warning, please use the following option:
1164[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1165[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:68:26
1166[warn] 68 | }(ExecutionContexts.parasitic)
1167[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1168[warn] |Implicit parameters should be provided with a `using` clause.
1169[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1170[warn] |To disable the warning, please use the following option:
1171[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1172[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:72:52
1173[warn] 72 | (consumerActor ? GetCommittedOffset(partition))(timeout)
1174[warn] | ^^^^^^^
1175[warn] |Implicit parameters should be provided with a `using` clause.
1176[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1177[warn] |To disable the warning, please use the following option:
1178[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1179[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:78:26
1180[warn] 78 | }(ExecutionContexts.parasitic)
1181[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1182[warn] |Implicit parameters should be provided with a `using` clause.
1183[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1184[warn] |To disable the warning, please use the following option:
1185[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1186[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:81:54
1187[warn] 81 | (consumerActor ? GetCommittedOffsets(partitions))(timeout)
1188[warn] | ^^^^^^^
1189[warn] |Implicit parameters should be provided with a `using` clause.
1190[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1191[warn] |To disable the warning, please use the following option:
1192[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1193[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/MetadataClient.scala:87:26
1194[warn] 87 | }(ExecutionContexts.parasitic)
1195[warn] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
1196[warn] |Implicit parameters should be provided with a `using` clause.
1197[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1198[warn] |To disable the warning, please use the following option:
1199[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1200[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/Producer.scala:145:26
1201[warn] 145 | ): Sink[(Envelope[K, V, _], Committable), Future[Done]] =
1202[warn] | ^
1203[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1204[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1205[warn] -- Warning: /build/repo/core/src/main/scala/akka/kafka/scaladsl/SendProducer.scala:24:73
1206[warn] 24 | private final val producerFuture = settings.createKafkaProducerAsync()(ec)
1207[warn] | ^^
1208[warn] |Implicit parameters should be provided with a `using` clause.
1209[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1210[warn] |To disable the warning, please use the following option:
1211[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1212[warn] there were 16 deprecation warnings; re-run with -deprecation for details
1213[warn] 124 warnings found
1214[info] done compiling
1215Starting build for ProjectRef(file:/build/repo/,clusterSharding) (akka-stream-kafka-cluster-sharding)... [1/3]
1216Compile scalacOptions: -encoding, UTF-8, --java-output-version:17, 8, -Wconf:cat=feature:w,cat=deprecation&msg=.*JavaConverters.*:s,cat=unchecked:w,cat=lint:w,cat=unused:w,cat=w-flag:w, -Wconf:msg=can be rewritten automatically under:s, -source:3.8
1217[info] compiling 1 Scala source to /build/repo/cluster-sharding/target/scala-3.8.0-RC5/classes ...
1218[warn] Failed to parse `-Wconf` configuration: cat=feature:w,cat=deprecation&msg=.*JavaConverters.*:s,cat=unchecked:w,cat=lint:w,cat=unused:w,cat=w-flag:w,msg=can be rewritten automatically under:s
1219[warn] unknown category: w-flag
1220[warn] unknown category: unused
1221[warn] unknown category: lint
1222[warn] Note: for multiple filters, use `-Wconf:filter1:action1,filter2:action2`
1223[warn] or alternatively `-Wconf:filter1:action1 -Wconf:filter2:action2`
1224[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:59:53
1225[warn] 59 | settings: ConsumerSettings[_, _]): Future[KafkaShardingMessageExtractor[M]] =
1226[warn] | ^
1227[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1228[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1229[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:59:56
1230[warn] 59 | settings: ConsumerSettings[_, _]): Future[KafkaShardingMessageExtractor[M]] =
1231[warn] | ^
1232[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1233[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1234[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:83:53
1235[warn] 83 | settings: ConsumerSettings[_, _]): CompletionStage[KafkaShardingMessageExtractor[M]] =
1236[warn] | ^
1237[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1238[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1239[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:83:56
1240[warn] 83 | settings: ConsumerSettings[_, _]): CompletionStage[KafkaShardingMessageExtractor[M]] =
1241[warn] | ^
1242[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1243[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1244[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:122:63
1245[warn] 122 | settings: ConsumerSettings[_, _]): Future[KafkaShardingNoEnvelopeExtractor[M]] =
1246[warn] | ^
1247[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1248[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1249[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:122:66
1250[warn] 122 | settings: ConsumerSettings[_, _]): Future[KafkaShardingNoEnvelopeExtractor[M]] =
1251[warn] | ^
1252[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1253[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1254[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:148:33
1255[warn] 148 | settings: ConsumerSettings[_, _]
1256[warn] | ^
1257[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1258[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1259[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:148:36
1260[warn] 148 | settings: ConsumerSettings[_, _]
1261[warn] | ^
1262[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1263[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1264[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:193:62
1265[warn] 193 | settings: ConsumerSettings[_, _]): Future[Int] = {
1266[warn] | ^
1267[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1268[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1269[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:193:65
1270[warn] 193 | settings: ConsumerSettings[_, _]): Future[Int] = {
1271[warn] | ^
1272[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1273[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1274[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:208:40
1275[warn] 208 | new ConcurrentHashMap[EntityTypeKey[_], akka.actor.typed.ActorRef[ConsumerRebalanceEvent]]()
1276[warn] | ^
1277[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1278[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1279[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:227:47
1280[warn] 227 | def rebalanceListener(typeKey: EntityTypeKey[_]): akka.actor.typed.ActorRef[ConsumerRebalanceEvent] = {
1281[warn] | ^
1282[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1283[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1284[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:254:65
1285[warn] 254 | typeKey: akka.cluster.sharding.typed.javadsl.EntityTypeKey[_]
1286[warn] | ^
1287[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1288[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1289[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:295:37
1290[warn] 295 | def apply(typeKey: EntityTypeKey[_]): Behavior[ConsumerRebalanceEvent] =
1291[warn] | ^
1292[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1293[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1294[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:60:100
1295[warn] 60 | getPartitionCount(topic, timeout, settings).map(new KafkaShardingMessageExtractor[M](_))(system.dispatcher)
1296[warn] | ^^^^^^^^^^^^^^^^^
1297[warn] |Implicit parameters should be provided with a `using` clause.
1298[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1299[warn] |To disable the warning, please use the following option:
1300[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1301[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:85:59
1302[warn] 85 | .map(new KafkaShardingMessageExtractor[M](_))(system.dispatcher)
1303[warn] | ^^^^^^^^^^^^^^^^^
1304[warn] |Implicit parameters should be provided with a `using` clause.
1305[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1306[warn] |To disable the warning, please use the following option:
1307[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1308[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:124:104
1309[warn] 124 | .map(partitions => new KafkaShardingNoEnvelopeExtractor[M](partitions, entityIdExtractor))(system.dispatcher)
1310[warn] | ^^^^^^^^^^^^^^^^^
1311[warn] |Implicit parameters should be provided with a `using` clause.
1312[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1313[warn] |To disable the warning, please use the following option:
1314[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1315[warn] -- Warning: /build/repo/cluster-sharding/src/main/scala/akka/kafka/cluster/sharding/KafkaClusterSharding.scala:152:15
1316[warn] 152 | system.dispatcher
1317[warn] | ^^^^^^^^^^^^^^^^^
1318[warn] |Implicit parameters should be provided with a `using` clause.
1319[warn] |This code can be rewritten automatically under -rewrite -source 3.7-migration.
1320[warn] |To disable the warning, please use the following option:
1321[warn] | "-Wconf:msg=Implicit parameters should be provided with a `using` clause:s"
1322[warn] 19 warnings found
1323[info] done compiling
1324Starting build for ProjectRef(file:/build/repo/,testkit) (akka-stream-kafka-testkit)... [2/3]
1325Compile scalacOptions: -encoding, UTF-8, --java-output-version:17, 8, -Wconf:cat=feature:w,cat=deprecation&msg=.*JavaConverters.*:s,cat=unchecked:w,cat=lint:w,cat=unused:w,cat=w-flag:w, -Wconf:msg=can be rewritten automatically under:s, -source:3.8
1326[info] compiling 14 Scala sources and 8 Java sources to /build/repo/testkit/target/scala-3.8.0-RC5/classes ...
1327[warn] Failed to parse `-Wconf` configuration: cat=feature:w,cat=deprecation&msg=.*JavaConverters.*:s,cat=unchecked:w,cat=lint:w,cat=unused:w,cat=w-flag:w,msg=can be rewritten automatically under:s
1328[warn] unknown category: w-flag
1329[warn] unknown category: unused
1330[warn] unknown category: lint
1331[warn] Note: for multiple filters, use `-Wconf:filter1:action1,filter2:action2`
1332[warn] or alternatively `-Wconf:filter1:action1 -Wconf:filter2:action2`
1333[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:37:45
1334[warn] 37 | val configureZooKeeper: GenericContainer[_] => Unit = _ => (),
1335[warn] | ^
1336[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1337[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1338[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:38:81
1339[warn] 38 | val configureZooKeeperConsumer: java.util.function.Consumer[GenericContainer[_]] =
1340[warn] | ^
1341[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1342[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1343[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:39:36
1344[warn] 39 | new Consumer[GenericContainer[_]]() {
1345[warn] | ^
1346[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1347[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1348[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:40:50
1349[warn] 40 | override def accept(arg: GenericContainer[_]): Unit = ()
1350[warn] | ^
1351[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1352[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1353[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:42:50
1354[warn] 42 | val configureSchemaRegistry: GenericContainer[_] => Unit = _ => ()
1355[warn] | ^
1356[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1357[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1358[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:171:66
1359[warn] 171 | def withConfigureZooKeeper(configureZooKeeper: GenericContainer[_] => Unit): KafkaTestkitTestcontainersSettings =
1360[warn] | ^
1361[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1362[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1363[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:180:79
1364[warn] 180 | configureZooKeeperConsumer: java.util.function.Consumer[GenericContainer[_]]
1365[warn] | ^
1366[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1367[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1368[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:189:48
1369[warn] 189 | configureSchemaRegistry: GenericContainer[_] => Unit
1370[warn] | ^
1371[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1372[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1373[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:248:43
1374[warn] 248 | configureZooKeeper: GenericContainer[_] => Unit = configureZooKeeper,
1375[warn] | ^
1376[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1377[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1378[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:249:79
1379[warn] 249 | configureZooKeeperConsumer: java.util.function.Consumer[GenericContainer[_]] = configureZooKeeperConsumer,
1380[warn] | ^
1381[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1382[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1383[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/KafkaTestkitTestcontainersSettings.scala:250:48
1384[warn] 250 | configureSchemaRegistry: GenericContainer[_] => Unit = configureSchemaRegistry
1385[warn] | ^
1386[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1387[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1388[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/ProducerResultFactory.scala:22:41
1389[warn] 22 | def recordMetadata(msg: ProducerRecord[_, _]): RecordMetadata = {
1390[warn] | ^
1391[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1392[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1393[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/ProducerResultFactory.scala:22:44
1394[warn] 22 | def recordMetadata(msg: ProducerRecord[_, _]): RecordMetadata = {
1395[warn] | ^
1396[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1397[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1398[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/internal/KafkaTestKit.scala:93:38
1399[warn] 93 | private var adminClientVar: Admin = _
1400[warn] | ^
1401[warn] |`= _` has been deprecated; use `= uninitialized` instead.
1402[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
1403[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1404[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/internal/TestcontainersKafka.scala:19:49
1405[warn] 19 | private var cluster: KafkaContainerCluster = _
1406[warn] | ^
1407[warn] |`= _` has been deprecated; use `= uninitialized` instead.
1408[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
1409[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1410[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/internal/TestcontainersKafka.scala:20:56
1411[warn] 20 | private var kafkaBootstrapServersInternal: String = _
1412[warn] | ^
1413[warn] |`= _` has been deprecated; use `= uninitialized` instead.
1414[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
1415[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1416[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/internal/TestcontainersKafka.scala:47:45
1417[warn] 47 | def zookeeperContainer: GenericContainer[_] = {
1418[warn] | ^
1419[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1420[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1421[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/scaladsl/KafkaSpec.scala:52:48
1422[warn] 52 | var testProducer: KProducer[String, String] = _
1423[warn] | ^
1424[warn] |`= _` has been deprecated; use `= uninitialized` instead.
1425[warn] |`uninitialized` can be imported with `scala.compiletime.uninitialized`.
1426[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1427[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/scaladsl/KafkaSpec.scala:79:38
1428[warn] 79 | awaitMultiple(4.seconds, futures: _*)
1429[warn] | ^
1430[warn] |The syntax `x: _*` is no longer supported for vararg splices; use `x*` instead
1431[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1432[warn] -- Warning: /build/repo/testkit/src/main/scala/akka/kafka/testkit/scaladsl/TestcontainersKafkaLike.scala:23:52
1433[warn] 23 | override def zookeeperContainer: GenericContainer[_] = TestcontainersKafka.Singleton.zookeeperContainer
1434[warn] | ^
1435[warn] |`_` is deprecated for wildcard arguments of types: use `?` instead
1436[warn] |This construct can be rewritten automatically under -rewrite -source 3.4-migration.
1437[warn] there were 4 deprecation warnings; re-run with -deprecation for details
1438[warn] 22 warnings found
1439[warn] /build/repo/testkit/src/main/java/akka/kafka/testkit/javadsl/BaseKafkaTest.java:40:17: akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKitClass implements akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKit
1440[warn] return type requires unchecked conversion from java.util.Map to java.util.Map<java.lang.String,java.lang.Object>
1441[warn] public abstract class BaseKafkaTest extends KafkaTestKitClass {
1442[warn]
1443[warn] public static final int partition0 = 0;
1444[warn]
1445[warn] public final Logger log = LoggerFactory.getLogger(getClass());
1446[warn]
1447[warn] protected final Materializer materializer;
1448[warn]
1449[warn] /**
1450[warn] * @deprecated Materializer no longer necessary in Akka 2.6, use
1451[warn] * `BaseKafkaTest(ClassicActorSystemProvider, String)` instead, since 2.1.0
1452[warn] */
1453[warn] @Deprecated
1454[warn] protected BaseKafkaTest(ActorSystem system, Materializer mat, String bootstrapServers) {
1455[warn] super(system, bootstrapServers);
1456[warn] this.materializer = mat;
1457[warn] }
1458[warn]
1459[warn] protected BaseKafkaTest(ClassicActorSystemProvider system, String bootstrapServers) {
1460[warn] this(system.classicSystem(), Materializer.matFromSystem(system), bootstrapServers);
1461[warn] }
1462[warn]
1463[warn] @Override
1464[warn] public Logger log() {
1465[warn] return log;
1466[warn] }
1467[warn]
1468[warn] /**
1469[warn] * Overwrite to set different default timeout for
1470[warn] * [[resultOf[T](stage:java\.util\.concurrent\.CompletionStage[T])* resultOf]].
1471[warn] */
1472[warn] protected Duration resultOfTimeout() {
1473[warn] return Duration.ofSeconds(5);
1474[warn] }
1475[warn]
1476[warn] protected CompletionStage<Done> produceString(String topic, int messageCount, int partition) {
1477[warn] return Source.fromIterator(() -> IntStream.range(0, messageCount).iterator())
1478[warn] .map(Object::toString)
1479[warn] .map(n -> new ProducerRecord<String, String>(topic, partition, DefaultKey(), n))
1480[warn] .runWith(Producer.plainSink(producerDefaults()), materializer);
1481[warn] }
1482[warn]
1483[warn] protected CompletionStage<Done> produceString(String topic, String message) {
1484[warn] return produce(
1485[warn] topic, StringSerializer(), StringSerializer(), Pair.create(DefaultKey(), message));
1486[warn] }
1487[warn]
1488[warn] @SafeVarargs
1489[warn] protected final <K, V> CompletionStage<Done> produce(
1490[warn] String topic,
1491[warn] Serializer<K> keySerializer,
1492[warn] Serializer<V> valueSerializer,
1493[warn] Pair<K, V>... messages) {
1494[warn] return Source.from(Arrays.asList(messages))
1495[warn] .map(pair -> new ProducerRecord<>(topic, pair.first(), pair.second()))
1496[warn] .runWith(
1497[warn] Producer.plainSink(producerDefaults(keySerializer, valueSerializer)), materializer);
1498[warn] }
1499[warn]
1500[warn] protected Consumer.DrainingControl<List<ConsumerRecord<String, String>>> consumeString(
1501[warn] String topic, long take) {
1502[warn] return consume(topic, take, StringDeserializer(), StringDeserializer());
1503[warn] }
1504[warn]
1505[warn] protected <K, V> Consumer.DrainingControl<List<ConsumerRecord<K, V>>> consume(
1506[warn] String topic, long take, Deserializer<K> keyDeserializer, Deserializer<V> valueDeserializer) {
1507[warn] return Consumer.plainSource(
1508[warn] consumerDefaults(keyDeserializer, valueDeserializer)
1509[warn] .withGroupId(createGroupId(1))
1510[warn] .withStopTimeout(Duration.ZERO),
1511[warn] Subscriptions.topics(topic))
1512[warn] .take(take)
1513[warn] .toMat(Sink.seq(), Consumer::createDrainingControl)
1514[warn] .run(materializer);
1515[warn] }
1516[warn]
1517[warn] /**
1518[warn] * Periodically checks if a given predicate on cluster state holds.
1519[warn] *
1520[warn] * <p>If the predicate does not hold after configured amount of time, throws an exception.
1521[warn] */
1522[warn] public void waitUntilCluster(Predicate<DescribeClusterResult> predicate) {
1523[warn] KafkaTestKitChecks.waitUntilCluster(
1524[warn] settings().clusterTimeout(),
1525[warn] settings().checkInterval(),
1526[warn] adminClient(),
1527[warn] new FromJavaPredicate<DescribeClusterResult>(predicate),
1528[warn] log());
1529[warn] }
1530[warn]
1531[warn] /**
1532[warn] * Periodically checks if the given predicate on consumer group state holds.
1533[warn] *
1534[warn] * <p>If the predicate does not hold after configured amount of time, throws an exception.
1535[warn] */
1536[warn] public void waitUntilConsumerGroup(
1537[warn] String groupId, Predicate<ConsumerGroupDescription> predicate) {
1538[warn] KafkaTestKitChecks.waitUntilConsumerGroup(
1539[warn] groupId,
1540[warn] settings().consumerGroupTimeout(),
1541[warn] settings().checkInterval(),
1542[warn] adminClient(),
1543[warn] new FromJavaPredicate<ConsumerGroupDescription>(predicate),
1544[warn] log());
1545[warn] }
1546[warn]
1547[warn] /**
1548[warn] * Periodically checks if the given predicate on consumer summary holds.
1549[warn] *
1550[warn] * <p>If the predicate does not hold after configured amount of time, throws an exception.
1551[warn] */
1552[warn] public void waitUntilConsumerSummary(
1553[warn] String groupId, Predicate<Collection<MemberDescription>> predicate) {
1554[warn] waitUntilConsumerGroup(
1555[warn] groupId,
1556[warn] group -> {
1557[warn] try {
1558[warn] return group.state() == ConsumerGroupState.STABLE && predicate.test(group.members());
1559[warn] } catch (Exception ex) {
1560[warn] return false;
1561[warn] }
1562[warn] });
1563[warn] }
1564[warn]
1565[warn] protected <T> T resultOf(CompletionStage<T> stage) throws Exception {
1566[warn] return resultOf(stage, resultOfTimeout());
1567[warn] }
1568[warn]
1569[warn] protected <T> T resultOf(CompletionStage<T> stage, Duration timeout) throws Exception {
1570[warn] return stage.toCompletableFuture().get(timeout.toMillis(), TimeUnit.MILLISECONDS);
1571[warn] }
1572[warn] }
1573[warn] ^
1574[warn] /build/repo/testkit/src/main/java/akka/kafka/testkit/javadsl/KafkaJunit4Test.java:16:17: akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKitClass implements akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKit
1575[warn] return type requires unchecked conversion from java.util.Map to java.util.Map<java.lang.String,java.lang.Object>
1576[warn] public abstract class KafkaJunit4Test extends BaseKafkaTest {
1577[warn]
1578[warn] /**
1579[warn] * @deprecated Materializer no longer necessary in Akka 2.6, use
1580[warn] * `KafkaJunit4Test(ClassicActorSystemProvider, String)` instead, since 2.1.0
1581[warn] */
1582[warn] @Deprecated
1583[warn] protected KafkaJunit4Test(ActorSystem system, Materializer mat, String bootstrapServers) {
1584[warn] super(system, mat, bootstrapServers);
1585[warn] }
1586[warn]
1587[warn] protected KafkaJunit4Test(ClassicActorSystemProvider system, String bootstrapServers) {
1588[warn] super(system, bootstrapServers);
1589[warn] }
1590[warn]
1591[warn] @Before
1592[warn] public void setUpAdmin() {
1593[warn] setUpAdminClient();
1594[warn] }
1595[warn]
1596[warn] @After
1597[warn] public void cleanUpAdmin() {
1598[warn] cleanUpAdminClient();
1599[warn] }
1600[warn]
1601[warn] @After
1602[warn] public void checkForStageLeaks() {
1603[warn] // you might need to configure `stop-timeout` in your `application.conf`
1604[warn] // as the default of 30s will fail this
1605[warn] StreamTestKit.assertAllStagesStopped(materializer);
1606[warn] }
1607[warn] }
1608[warn] ^
1609[warn] /build/repo/testkit/src/main/java/akka/kafka/testkit/javadsl/KafkaTest.java:22:17: akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKitClass implements akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKit
1610[warn] return type requires unchecked conversion from java.util.Map to java.util.Map<java.lang.String,java.lang.Object>
1611[warn] public abstract class KafkaTest extends BaseKafkaTest {
1612[warn]
1613[warn] /**
1614[warn] * @deprecated Materializer no longer necessary in Akka 2.6, use
1615[warn] * `KafkaTest(ClassicActorSystemProvider, String)` instead, since 2.1.0
1616[warn] */
1617[warn] @Deprecated
1618[warn] protected KafkaTest(ActorSystem system, Materializer mat, String bootstrapServers) {
1619[warn] super(system, mat, bootstrapServers);
1620[warn] }
1621[warn]
1622[warn] protected KafkaTest(ClassicActorSystemProvider system, String bootstrapServers) {
1623[warn] super(system, bootstrapServers);
1624[warn] }
1625[warn]
1626[warn] @BeforeAll
1627[warn] public void setupAdmin() {
1628[warn] setUpAdminClient();
1629[warn] }
1630[warn]
1631[warn] @AfterAll
1632[warn] public void cleanUpAdmin() {
1633[warn] cleanUpAdminClient();
1634[warn] }
1635[warn]
1636[warn] @AfterEach
1637[warn] public void checkForStageLeaks() {
1638[warn] // you might need to configure `stop-timeout` in your `application.conf`
1639[warn] // as the default of 30s will fail this
1640[warn] StreamTestKit.assertAllStagesStopped(materializer);
1641[warn] }
1642[warn] }
1643[warn] ^
1644[warn] /build/repo/testkit/src/main/java/akka/kafka/testkit/javadsl/TestcontainersKafkaJunit4Test.java:23:17: akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKitClass implements akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKit
1645[warn] return type requires unchecked conversion from java.util.Map to java.util.Map<java.lang.String,java.lang.Object>
1646[warn] public abstract class TestcontainersKafkaJunit4Test extends KafkaJunit4Test {
1647[warn]
1648[warn] private static final KafkaTestkitTestcontainersSettings settings =
1649[warn] TestcontainersKafka.Singleton().testcontainersSettings();
1650[warn]
1651[warn] /**
1652[warn] * @deprecated Materializer no longer necessary in Akka 2.6, use
1653[warn] * `TestcontainersKafkaJunit4Test(ClassicActorSystemProvider)` instead, since 2.1.0
1654[warn] */
1655[warn] @Deprecated
1656[warn] protected TestcontainersKafkaJunit4Test(ActorSystem system, Materializer mat) {
1657[warn] super(system, mat, startKafka(settings));
1658[warn] }
1659[warn]
1660[warn] protected TestcontainersKafkaJunit4Test(ClassicActorSystemProvider system) {
1661[warn] super(system, startKafka(settings));
1662[warn] }
1663[warn]
1664[warn] protected TestcontainersKafkaJunit4Test(
1665[warn] ActorSystem system, KafkaTestkitTestcontainersSettings settings) {
1666[warn] super(system, startKafka(settings));
1667[warn] }
1668[warn]
1669[warn] protected static String startKafka(KafkaTestkitTestcontainersSettings settings) {
1670[warn] return TestcontainersKafka.Singleton().startCluster(settings);
1671[warn] }
1672[warn]
1673[warn] protected static void stopKafka() {
1674[warn] TestcontainersKafka.Singleton().stopCluster();
1675[warn] }
1676[warn]
1677[warn] @Before
1678[warn] @Override
1679[warn] public void setUpAdminClient() {
1680[warn] super.setUpAdminClient();
1681[warn] }
1682[warn]
1683[warn] @After
1684[warn] @Override
1685[warn] public void cleanUpAdminClient() {
1686[warn] super.cleanUpAdminClient();
1687[warn] }
1688[warn]
1689[warn] protected String getSchemaRegistryUrl() {
1690[warn] return TestcontainersKafka.Singleton().getSchemaRegistryUrl();
1691[warn] }
1692[warn] }
1693[warn] ^
1694[warn] /build/repo/testkit/src/main/java/akka/kafka/testkit/javadsl/TestcontainersKafkaTest.java:25:17: akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKitClass implements akka$kafka$testkit$internal$KafkaTestKit$$adminDefaults() in akka.kafka.testkit.internal.KafkaTestKit
1695[warn] return type requires unchecked conversion from java.util.Map to java.util.Map<java.lang.String,java.lang.Object>
1696[warn] public abstract class TestcontainersKafkaTest extends KafkaTest {
1697[warn]
1698[warn] public static final KafkaTestkitTestcontainersSettings settings =
1699[warn] TestcontainersKafka.Singleton().testcontainersSettings();
1700[warn]
1701[warn] /**
1702[warn] * @deprecated Materializer no longer necessary in Akka 2.6, use
1703[warn] * `TestcontainersKafkaTest(ClassicActorSystemProvider)` instead, since 2.1.0
1704[warn] */
1705[warn] @Deprecated
1706[warn] protected TestcontainersKafkaTest(ActorSystem system, Materializer mat) {
1707[warn] super(system, mat, startKafka(settings));
1708[warn] }
1709[warn]
1710[warn] protected TestcontainersKafkaTest(ClassicActorSystemProvider system) {
1711[warn] super(system, startKafka(settings));
1712[warn] }
1713[warn]
1714[warn] protected TestcontainersKafkaTest(
1715[warn] ActorSystem system, KafkaTestkitTestcontainersSettings settings) {
1716[warn] super(system, startKafka(settings));
1717[warn] }
1718[warn]
1719[warn] protected static String startKafka(KafkaTestkitTestcontainersSettings settings) {
1720[warn] return TestcontainersKafka.Singleton().startCluster(settings);
1721[warn] }
1722[warn]
1723[warn] protected static void stopKafka() {
1724[warn] TestcontainersKafka.Singleton().stopCluster();
1725[warn] }
1726[warn]
1727[warn] protected String getSchemaRegistryUrl() {
1728[warn] return TestcontainersKafka.Singleton().getSchemaRegistryUrl();
1729[warn] }
1730[warn] }
1731[warn] ^
1732[info] done compiling
1733
1734************************
1735Build summary:
1736[{
1737 "module": "akka-stream-kafka",
1738 "compile": {"status": "ok", "tookMs": 15408, "warnings": 122, "errors": 0, "sourceVersion": "3.8"},
1739 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},
1740 "test-compile": {"status": "ok", "tookMs": 147, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},
1741 "test": {"status": "ok", "tookMs": 111, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},
1742 "publish": {"status": "skipped", "tookMs": 0},
1743 "metadata": {
1744 "crossScalaVersions": ["2.13.10", "2.12.17", "3.2.2"]
1745}
1746},{
1747 "module": "akka-stream-kafka-cluster-sharding",
1748 "compile": {"status": "ok", "tookMs": 1054, "warnings": 18, "errors": 0, "sourceVersion": "3.8"},
1749 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},
1750 "test-compile": {"status": "ok", "tookMs": 155, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},
1751 "test": {"status": "ok", "tookMs": 227, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},
1752 "publish": {"status": "skipped", "tookMs": 0},
1753 "metadata": {
1754 "crossScalaVersions": ["2.13.10", "2.12.17", "3.2.2"]
1755}
1756},{
1757 "module": "akka-stream-kafka-testkit",
1758 "compile": {"status": "ok", "tookMs": 3313, "warnings": 20, "errors": 0, "sourceVersion": "3.8"},
1759 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},
1760 "test-compile": {"status": "ok", "tookMs": 188, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},
1761 "test": {"status": "ok", "tookMs": 123, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},
1762 "publish": {"status": "skipped", "tookMs": 0},
1763 "metadata": {
1764 "crossScalaVersions": ["2.13.10", "2.12.17", "3.2.2"]
1765}
1766}]
1767************************
1768[success] Total time: 26 s, completed Dec 31, 2025, 9:11:18 PM
1769[0JChecking patch project/plugins.sbt...
1770Checking patch project/build.properties...
1771Checking patch build.sbt...
1772Applied patch project/plugins.sbt cleanly.
1773Applied patch project/build.properties cleanly.
1774Applied patch build.sbt cleanly.