Build Logs

akka/alpakka-kafka • 3.8.0-RC2:2025-11-25

Errors

6

Warnings

1305

Total Lines

1775

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