Build Logs

fd4s/fs2-kafka • 3.8.1-RC1:2026-01-13

Errors

Warnings

Total Lines

3547

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

2Clonning https://github.com/fd4s/fs2-kafka.git into /build/repo using revision v3.9.1

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

4Note: switching to 'bc8f95d8b646d8721c7362bf51a4b7d46e3e57f7'.

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.

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:

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

15Or undo this operation with:

17 git switch -

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

21Would override fixed Scala version: 3.3.6

22Using target Scala version for migration: 3.7.4

23Migrating project for -source:3.4 using Scala 3.7.4

24----

25Preparing build for 3.7.4

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

27Append: -rewrite,REQUIRE:-source:3.4-migration

28Remove: -indent,-no-indent,-new-syntax,,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

30Try apply source patch:

31Path: build.sbt

32Pattern: val scala3 = "3.3.6"

33Replacement: val scala3 = "3.7.4"

34Starting compilation server

35Compiling project (Scala 3.7.3, JVM (21))

36Compiled project (Scala 3.7.3, JVM (21))

37Successfully applied pattern 'val scala3 = "3.3.6"' in build.sbt

38----

39Starting build for 3.7.4

40Execute tests: false

41sbt project found:

42No prepare script found for project fd4s/fs2-kafka

43##################################

44Scala version: 3.7.4

45Targets: com.github.fd4s%fs2-kafka com.github.fd4s%fs2-kafka-vulcan com.github.fd4s%fs2-kafka-vulcan-testkit-munit

46Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}

47##################################

48Using extra scalacOptions: -rewrite,REQUIRE:-source:3.4-migration

49Filtering out scalacOptions: -indent,-no-indent,-new-syntax,,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

50[sbt_options] declare -a sbt_options=()

51[process_args] java_version = '21'

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

53# Executing command line:

54java

55-Dfile.encoding=UTF-8

56-Dcommunitybuild.scala=3.7.4

57-Dcommunitybuild.project.dependencies.add=

58-Xmx7G

59-Xms4G

60-Xss8M

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

62-Dscala.ext.dirs=/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_21

63-jar

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

65"setCrossScalaVersions 3.7.4"

66"++3.7.4 -v"

67"mapScalacOptions "-rewrite,REQUIRE:-source:3.4-migration,-Wconf:msg=can be rewritten automatically under:s" "-indent,-no-indent,-new-syntax,,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e""

68"set every credentials := Nil"

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

70"removeScalacOptionsStartingWith -P:wartremover"

71"set core/Test/unmanagedSources/excludeFilter ~= {_ || "KafkaProducerConnectionSpec.scala" || "KafkaConsumerSpec.scala" || "KafkaProducerSpec.scala" || "TransactionalKafkaProducerSpec.scala" || "TransactionalKafkaProducerTimeoutSpec.scala" || "KafkaAdminClientSpec.scala"} "

72moduleMappings

73"runBuild 3.7.4 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}""" com.github.fd4s%fs2-kafka com.github.fd4s%fs2-kafka-vulcan com.github.fd4s%fs2-kafka-vulcan-testkit-munit"

75[info] [launcher] getting org.scala-sbt sbt 1.11.7 (this may take some time)...

76[info] welcome to sbt 1.11.7 (Eclipse Adoptium Java 21)

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

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

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

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

81[info] Compilation completed in 8.3s.

82[info] done compiling

83[info] loading settings for project fs2-kafka from build.sbt...

84[info] set scmInfo to https://github.com/fd4s/fs2-kafka

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

86Execute setCrossScalaVersions: 3.7.4

87OpenCB::Changing crossVersion 3.7.4 -> 3.7.4 in core/crossScalaVersions

88[info] set scmInfo to https://github.com/fd4s/fs2-kafka

89OpenCB::Changing crossVersion 3.7.4 -> 3.7.4 in vulcan-testkit-munit/crossScalaVersions

90OpenCB::Changing crossVersion 3.7.4 -> 3.7.4 in vulcan/crossScalaVersions

91OpenCB::Changing crossVersion 3.7.4 -> 3.7.4 in fs2-kafka/crossScalaVersions

92[info] set current project to fs2-kafka (in build file:/build/repo/)

93[info] Setting Scala version to 3.7.4 on 4 projects.

94[info] Switching Scala version on:

95[info] * fs2-kafka (2.12.20, 2.13.17, 3.7.4)

96[info] vulcan-testkit-munit (2.12.20, 2.13.17, 3.7.4)

97[info] core (2.12.20, 2.13.17, 3.7.4)

98[info] vulcan (2.12.20, 2.13.17, 3.7.4)

99[info] Excluding projects:

100[info] docs (2.13.17)

101[info] Reapplying settings...

102[info] set scmInfo to https://github.com/fd4s/fs2-kafka

103[info] set current project to fs2-kafka (in build file:/build/repo/)

104Execute mapScalacOptions: -rewrite,REQUIRE:-source:3.4-migration,-Wconf:msg=can be rewritten automatically under:s -indent,-no-indent,-new-syntax,,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

105[info] Reapplying settings...

106[info] set scmInfo to https://github.com/fd4s/fs2-kafka

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

108[info] Defining Global / credentials, core / credentials and 3 others.

109[info] The new values will be used by Compile / scalafmtOnly, IntegrationTest / scalafmtOnly and 42 others.

110[info] Run `last` for details.

111[info] Reapplying settings...

112[info] set scmInfo to https://github.com/fd4s/fs2-kafka

113[info] set current project to fs2-kafka (in build file:/build/repo/)

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

115[info] Reapplying settings...

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

117

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

119 Did you mean allExcludeDependencies ?

120 , retry without global scopes

121[info] Reapplying settings...

122[info] set scmInfo to https://github.com/fd4s/fs2-kafka

123[info] set current project to fs2-kafka (in build file:/build/repo/)

124Execute removeScalacOptionsStartingWith: -P:wartremover

125[info] Reapplying settings...

126[info] set scmInfo to https://github.com/fd4s/fs2-kafka

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

128[info] Defining core / Test / unmanagedSources / excludeFilter

129[info] The new value will be used by core / Test / unmanagedSources / fileInputs

130[info] Reapplying settings...

131[info] set scmInfo to https://github.com/fd4s/fs2-kafka

132[info] set current project to fs2-kafka (in build file:/build/repo/)

133[success] Total time: 0 s, completed Jan 13, 2026, 8:17:03 PM

134Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}

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

136Starting build...

137Projects: Set(fs2-kafka, vulcan, vulcan-testkit-munit, core)

138Starting build for ProjectRef(file:/build/repo/,fs2-kafka) (fs2-kafka)... [0/4]

139OpenCB::Exclude Scala3 specific scalacOption `-rewrite` in Scala 2.12.20 module Global

140OpenCB::Exclude Scala3 specific scalacOption `REQUIRE:-source:3.4-migration` in Scala 2.12.20 module Global

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

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

143Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, -java-output-version, 8, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.4-migration

144Starting build for ProjectRef(file:/build/repo/,vulcan) (fs2-kafka-vulcan)... [1/4]

145Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, -java-output-version, 8, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.4-migration

146[info] compiling 65 Scala sources to /build/repo/modules/core/target/scala-3.7.4/classes ...

147[warn] -- [E198] Unused Symbol Warning: /build/repo/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala:685:46

148[warn] 685 | implicit final class StreamOps[F[_]: Functor, K, V](self: Stream[F, KafkaConsumer[F, K, V]]) {

149[warn] | ^

150[warn] | unused implicit parameter

151[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/Headers.scala]

152[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/CommitRecovery.scala]

153[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/ConsumerSettings.scala]

154[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/Header.scala]

155[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/KafkaAdminClient.scala]

156[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/ProducerSettings.scala]

157[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/internal/KafkaConsumerActor.scala]

158[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/AdminClientSettings.scala]

159[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/TransactionalProducerSettings.scala]

160[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala]

161[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala]

162[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/Deserializer.scala]

163[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala]

164[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/ProducerRecord.scala]

165[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/TransactionalKafkaProducer.scala]

166[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/CommittableProducerRecords.scala]

167[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/Serializer.scala]

168[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/CommittableConsumerRecord.scala]

169[warn] one warning found

170[info] done compiling

171[info] compiling 6 Scala sources to /build/repo/modules/vulcan/target/scala-3.7.4/classes ...

172[info] [patched file /build/repo/modules/vulcan/src/main/scala/fs2/kafka/vulcan/SchemaRegistryClientSettings.scala]

173[info] [patched file /build/repo/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala]

174[info] done compiling

175[info] compiling 18 Scala sources to /build/repo/modules/core/target/scala-3.7.4/classes ...

176[warn] -- [E198] Unused Symbol Warning: /build/repo/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala:685:46

177[warn] 685 | implicit final class StreamOps[F[_]: Functor, K, V](self: Stream[F, KafkaConsumer[F, K, V]]) {

178[warn] | ^

179[warn] | unused implicit parameter

180[warn] one warning found

181[info] done compiling

182[info] compiling 2 Scala sources to /build/repo/modules/vulcan/target/scala-3.7.4/classes ...

183[info] done compiling

184[info] compiling 6 Scala sources to /build/repo/modules/vulcan/target/scala-3.7.4/test-classes ...

185[info] done compiling

186Starting build for ProjectRef(file:/build/repo/,vulcan-testkit-munit) (fs2-kafka-vulcan-testkit-munit)... [2/4]

187Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, -java-output-version, 8, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.4-migration

188[info] compiling 1 Scala source to /build/repo/modules/vulcan-testkit-munit/target/scala-3.7.4/classes ...

189[info] done compiling

190Starting build for ProjectRef(file:/build/repo/,core) (fs2-kafka)... [3/4]

191Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, -java-output-version, 8, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.4-migration

192[info] compiling 42 Scala sources to /build/repo/modules/core/target/scala-3.7.4/test-classes ...

193[info] [patched file /build/repo/modules/core/src/test/scala/fs2/kafka/CommittableOffsetBatchSpec.scala]

194[info] [patched file /build/repo/modules/core/src/test/scala/fs2/kafka/BaseKafkaSpec.scala]

195[info] done compiling

196[info] compiling 2 Scala sources to /build/repo/modules/core/target/scala-3.7.4/test-classes ...

197[info] done compiling

198

199************************

200Build summary:

201[{

202 "module": "fs2-kafka",

203 "compile": {"status": "ok", "tookMs": 171, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

205 "test-compile": {"status": "ok", "tookMs": 111, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

207 "publish": {"status": "ok", "tookMs": 4},

208 "metadata": {

209 "crossScalaVersions": ["2.12.20", "2.13.17", "3.3.6"]

210}

211},{

212 "module": "fs2-kafka-vulcan",

213 "compile": {"status": "ok", "tookMs": 19780, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

215 "test-compile": {"status": "ok", "tookMs": 9692, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

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

218 "metadata": {

219 "crossScalaVersions": ["2.12.20", "2.13.17", "3.3.6"]

220}

221},{

222 "module": "fs2-kafka-vulcan-testkit-munit",

223 "compile": {"status": "ok", "tookMs": 729, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

225 "test-compile": {"status": "ok", "tookMs": 209, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

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

228 "metadata": {

229 "crossScalaVersions": ["2.12.20", "2.13.17", "3.3.6"]

230}

231},{

232 "module": "fs2-kafka",

233 "compile": {"status": "ok", "tookMs": 42, "warnings": 1, "errors": 0, "sourceVersion": "3.4-migration"},

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

235 "test-compile": {"status": "ok", "tookMs": 13773, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

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

238 "metadata": {

239 "crossScalaVersions": ["2.12.20", "2.13.17", "3.3.6"]

240}

241}]

242************************

243[success] Total time: 67 s (0:01:07.0), completed Jan 13, 2026, 8:18:10 PM

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

245Checking patch build.sbt...

246Applied patch project/plugins.sbt cleanly.

247Applied patch build.sbt cleanly.

248Commit migration rewrites

249Switched to a new branch 'opencb/migrate-source-3.4'

250[opencb/migrate-source-3.4 e2bea4b7] Apply Scala compiler rewrites using -source:3.4-migration using Scala 3.7.4

251 22 files changed, 69 insertions(+), 69 deletions(-)

252----

253Preparing build for 3.8.1-RC1

254Scala binary version found: 3.8

255Implicitly using source version 3.8

256Scala binary version found: 3.8

257Implicitly using source version 3.8

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

259Append: ,REQUIRE:-source:3.8

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

261

262Try apply source patch:

263Path: build.sbt

264Pattern: val scala3 = "3.3.6"

265Replacement: val scala3 = "3.8.1-RC1"

266Successfully applied pattern 'val scala3 = "3.3.6"' in build.sbt

267----

268Starting build for 3.8.1-RC1

269Execute tests: true

270sbt project found:

271No prepare script found for project fd4s/fs2-kafka

272##################################

273Scala version: 3.8.1-RC1

274Targets: com.github.fd4s%fs2-kafka com.github.fd4s%fs2-kafka-vulcan com.github.fd4s%fs2-kafka-vulcan-testkit-munit

275Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}

276##################################

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

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

279[sbt_options] declare -a sbt_options=()

280[process_args] java_version = '21'

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

282# Executing command line:

283java

284-Dfile.encoding=UTF-8

285-Dcommunitybuild.scala=3.8.1-RC1

286-Dcommunitybuild.project.dependencies.add=

287-Xmx7G

288-Xms4G

289-Xss8M

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

291-Dscala.ext.dirs=/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_21

292-jar

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

294"setCrossScalaVersions 3.8.1-RC1"

295"++3.8.1-RC1 -v"

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

297"set every credentials := Nil"

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

299"removeScalacOptionsStartingWith -P:wartremover"

300"set core/Test/unmanagedSources/excludeFilter ~= {_ || "KafkaProducerConnectionSpec.scala" || "KafkaConsumerSpec.scala" || "KafkaProducerSpec.scala" || "TransactionalKafkaProducerSpec.scala" || "TransactionalKafkaProducerTimeoutSpec.scala" || "KafkaAdminClientSpec.scala"} "

301moduleMappings

302"runBuild 3.8.1-RC1 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}""" com.github.fd4s%fs2-kafka com.github.fd4s%fs2-kafka-vulcan com.github.fd4s%fs2-kafka-vulcan-testkit-munit"

303

304[info] welcome to sbt 1.11.7 (Eclipse Adoptium Java 21)

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

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

307[info] loading settings for project fs2-kafka from build.sbt...

308[info] set scmInfo to https://github.com/fd4s/fs2-kafka

309[info] set current project to fs2-kafka (in build file:/build/repo/)

310Execute setCrossScalaVersions: 3.8.1-RC1

311[info] set scmInfo to https://github.com/fd4s/fs2-kafka

312OpenCB::Changing crossVersion 3.8.1-RC1 -> 3.8.1-RC1 in core/crossScalaVersions

313OpenCB::Changing crossVersion 3.8.1-RC1 -> 3.8.1-RC1 in vulcan/crossScalaVersions

314OpenCB::Changing crossVersion 3.8.1-RC1 -> 3.8.1-RC1 in vulcan-testkit-munit/crossScalaVersions

315OpenCB::Changing crossVersion 3.8.1-RC1 -> 3.8.1-RC1 in fs2-kafka/crossScalaVersions

316[info] set current project to fs2-kafka (in build file:/build/repo/)

317[info] Setting Scala version to 3.8.1-RC1 on 4 projects.

318[info] Switching Scala version on:

319[info] * fs2-kafka (2.12.20, 2.13.17, 3.8.1-RC1)

320[info] vulcan-testkit-munit (2.12.20, 2.13.17, 3.8.1-RC1)

321[info] core (2.12.20, 2.13.17, 3.8.1-RC1)

322[info] vulcan (2.12.20, 2.13.17, 3.8.1-RC1)

323[info] Excluding projects:

324[info] docs (2.13.17)

325[info] Reapplying settings...

326[info] set scmInfo to https://github.com/fd4s/fs2-kafka

327[info] set current project to fs2-kafka (in build file:/build/repo/)

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

329[info] Reapplying settings...

330[info] set scmInfo to https://github.com/fd4s/fs2-kafka

331[info] set current project to fs2-kafka (in build file:/build/repo/)

332[info] Defining Global / credentials, core / credentials and 3 others.

333[info] The new values will be used by Compile / scalafmtOnly, IntegrationTest / scalafmtOnly and 42 others.

334[info] Run `last` for details.

335[info] Reapplying settings...

336[info] set scmInfo to https://github.com/fd4s/fs2-kafka

337[info] set current project to fs2-kafka (in build file:/build/repo/)

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

339[info] Reapplying settings...

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

341

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

343 Did you mean allExcludeDependencies ?

344 , retry without global scopes

345[info] Reapplying settings...

346[info] set scmInfo to https://github.com/fd4s/fs2-kafka

347[info] set current project to fs2-kafka (in build file:/build/repo/)

348Execute removeScalacOptionsStartingWith: -P:wartremover

349[info] Reapplying settings...

350[info] set scmInfo to https://github.com/fd4s/fs2-kafka

351[info] set current project to fs2-kafka (in build file:/build/repo/)

352[info] Defining core / Test / unmanagedSources / excludeFilter

353[info] The new value will be used by core / Test / unmanagedSources / fileInputs

354[info] Reapplying settings...

355[info] set scmInfo to https://github.com/fd4s/fs2-kafka

356[info] set current project to fs2-kafka (in build file:/build/repo/)

357[success] Total time: 0 s, completed Jan 13, 2026, 8:18:29 PM

358Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}

359Parsed config: Success(ProjectBuildConfig(ProjectsConfig(List(),Map()),Full,List()))

360Starting build...

361Projects: Set(fs2-kafka, vulcan, vulcan-testkit-munit, core)

362Starting build for ProjectRef(file:/build/repo/,fs2-kafka) (fs2-kafka)... [0/4]

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

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

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

366Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

367Starting build for ProjectRef(file:/build/repo/,vulcan) (fs2-kafka-vulcan)... [1/4]

368Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

369[info] compiling 65 Scala sources to /build/repo/modules/core/target/scala-3.8.1-RC1/classes ...

370[warn] -- [E198] Unused Symbol Warning: /build/repo/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala:685:46

371[warn] 685 | implicit final class StreamOps[F[_]: Functor, K, V](self: Stream[F, KafkaConsumer[F, K, V]]) {

372[warn] | ^

373[warn] | unused implicit parameter

374[warn] one warning found

375[info] done compiling

376[info] compiling 6 Scala sources to /build/repo/modules/vulcan/target/scala-3.8.1-RC1/classes ...

377[info] done compiling

378[info] compiling 6 Scala sources to /build/repo/modules/vulcan/target/scala-3.8.1-RC1/test-classes ...

379[info] done compiling

380[info] PackageSpec:

381[info] avroSerializer

382[info] - should be available given explicit settings (354 milliseconds)

383[info] avroDeserializer

384[info] - should be available given explicit settings (3 milliseconds)

385[info] avroSerializer/avroDeserializer

38620:18:58.764 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

387 auto.register.schemas = true

388 avro.reflection.allow.null = false

389 avro.use.logical.type.converters = false

390 basic.auth.credentials.source = URL

391 basic.auth.user.info = [hidden]

392 bearer.auth.cache.expiry.buffer.seconds = 300

393 bearer.auth.client.id = null

394 bearer.auth.client.secret = null

395 bearer.auth.credentials.source = STATIC_TOKEN

396 bearer.auth.custom.provider.class = null

397 bearer.auth.identity.pool.id = null

398 bearer.auth.issuer.endpoint.url = null

399 bearer.auth.logical.cluster = null

400 bearer.auth.scope = null

401 bearer.auth.scope.claim.name = scope

402 bearer.auth.sub.claim.name = sub

403 bearer.auth.token = [hidden]

404 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

405 http.connect.timeout.ms = 60000

406 http.read.timeout.ms = 60000

407 id.compatibility.strict = true

408 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

409 latest.cache.size = 1000

410 latest.cache.ttl.sec = -1

411 latest.compatibility.strict = true

412 max.retries = 3

413 max.schemas.per.subject = 1000

414 normalize.schemas = false

415 propagate.schema.tags = false

416 proxy.host =

417 proxy.port = -1

418 retries.max.wait.ms = 20000

419 retries.wait.ms = 1000

420 rule.actions = []

421 rule.executors = []

422 rule.service.loader.enable = true

423 schema.format = null

424 schema.reflection = false

425 schema.registry.basic.auth.user.info = [hidden]

426 schema.registry.ssl.cipher.suites = null

427 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

428 schema.registry.ssl.endpoint.identification.algorithm = https

429 schema.registry.ssl.engine.factory.class = null

430 schema.registry.ssl.key.password = null

431 schema.registry.ssl.keymanager.algorithm = SunX509

432 schema.registry.ssl.keystore.certificate.chain = null

433 schema.registry.ssl.keystore.key = null

434 schema.registry.ssl.keystore.location = null

435 schema.registry.ssl.keystore.password = null

436 schema.registry.ssl.keystore.type = JKS

437 schema.registry.ssl.protocol = TLSv1.3

438 schema.registry.ssl.provider = null

439 schema.registry.ssl.secure.random.implementation = null

440 schema.registry.ssl.trustmanager.algorithm = PKIX

441 schema.registry.ssl.truststore.certificates = null

442 schema.registry.ssl.truststore.location = null

443 schema.registry.ssl.truststore.password = null

444 schema.registry.ssl.truststore.type = JKS

445 schema.registry.url = []

446 schema.registry.url.randomize = false

447 specific.avro.key.type = null

448 specific.avro.reader = false

449 specific.avro.value.type = null

450 use.latest.version = false

451 use.latest.with.metadata = null

452 use.schema.id = -1

453 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

454

45520:18:58.764 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

456 auto.register.schemas = true

457 avro.reflection.allow.null = false

458 avro.remove.java.properties = false

459 avro.use.logical.type.converters = false

460 basic.auth.credentials.source = URL

461 basic.auth.user.info = [hidden]

462 bearer.auth.cache.expiry.buffer.seconds = 300

463 bearer.auth.client.id = null

464 bearer.auth.client.secret = null

465 bearer.auth.credentials.source = STATIC_TOKEN

466 bearer.auth.custom.provider.class = null

467 bearer.auth.identity.pool.id = null

468 bearer.auth.issuer.endpoint.url = null

469 bearer.auth.logical.cluster = null

470 bearer.auth.scope = null

471 bearer.auth.scope.claim.name = scope

472 bearer.auth.sub.claim.name = sub

473 bearer.auth.token = [hidden]

474 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

475 http.connect.timeout.ms = 60000

476 http.read.timeout.ms = 60000

477 id.compatibility.strict = true

478 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

479 latest.cache.size = 1000

480 latest.cache.ttl.sec = -1

481 latest.compatibility.strict = true

482 max.retries = 3

483 max.schemas.per.subject = 1000

484 normalize.schemas = false

485 propagate.schema.tags = false

486 proxy.host =

487 proxy.port = -1

488 retries.max.wait.ms = 20000

489 retries.wait.ms = 1000

490 rule.actions = []

491 rule.executors = []

492 rule.service.loader.enable = true

493 schema.format = null

494 schema.reflection = false

495 schema.registry.basic.auth.user.info = [hidden]

496 schema.registry.ssl.cipher.suites = null

497 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

498 schema.registry.ssl.endpoint.identification.algorithm = https

499 schema.registry.ssl.engine.factory.class = null

500 schema.registry.ssl.key.password = null

501 schema.registry.ssl.keymanager.algorithm = SunX509

502 schema.registry.ssl.keystore.certificate.chain = null

503 schema.registry.ssl.keystore.key = null

504 schema.registry.ssl.keystore.location = null

505 schema.registry.ssl.keystore.password = null

506 schema.registry.ssl.keystore.type = JKS

507 schema.registry.ssl.protocol = TLSv1.3

508 schema.registry.ssl.provider = null

509 schema.registry.ssl.secure.random.implementation = null

510 schema.registry.ssl.trustmanager.algorithm = PKIX

511 schema.registry.ssl.truststore.certificates = null

512 schema.registry.ssl.truststore.location = null

513 schema.registry.ssl.truststore.password = null

514 schema.registry.ssl.truststore.type = JKS

515 schema.registry.url = []

516 schema.registry.url.randomize = false

517 use.latest.version = false

518 use.latest.with.metadata = null

519 use.schema.id = -1

520 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

521

522[info] - should be able to do roundtrip serialization (342 milliseconds)

52320:18:58.859 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

524 auto.register.schemas = true

525 avro.reflection.allow.null = false

526 avro.use.logical.type.converters = false

527 basic.auth.credentials.source = URL

528 basic.auth.user.info = [hidden]

529 bearer.auth.cache.expiry.buffer.seconds = 300

530 bearer.auth.client.id = null

531 bearer.auth.client.secret = null

532 bearer.auth.credentials.source = STATIC_TOKEN

533 bearer.auth.custom.provider.class = null

534 bearer.auth.identity.pool.id = null

535 bearer.auth.issuer.endpoint.url = null

536 bearer.auth.logical.cluster = null

537 bearer.auth.scope = null

538 bearer.auth.scope.claim.name = scope

539 bearer.auth.sub.claim.name = sub

540 bearer.auth.token = [hidden]

541 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

542 http.connect.timeout.ms = 60000

543 http.read.timeout.ms = 60000

544 id.compatibility.strict = true

545 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

546 latest.cache.size = 1000

547 latest.cache.ttl.sec = -1

548 latest.compatibility.strict = true

549 max.retries = 3

550 max.schemas.per.subject = 1000

551 normalize.schemas = false

552 propagate.schema.tags = false

553 proxy.host =

554 proxy.port = -1

555 retries.max.wait.ms = 20000

556 retries.wait.ms = 1000

557 rule.actions = []

558 rule.executors = []

559 rule.service.loader.enable = true

560 schema.format = null

561 schema.reflection = false

562 schema.registry.basic.auth.user.info = [hidden]

563 schema.registry.ssl.cipher.suites = null

564 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

565 schema.registry.ssl.endpoint.identification.algorithm = https

566 schema.registry.ssl.engine.factory.class = null

567 schema.registry.ssl.key.password = null

568 schema.registry.ssl.keymanager.algorithm = SunX509

569 schema.registry.ssl.keystore.certificate.chain = null

570 schema.registry.ssl.keystore.key = null

571 schema.registry.ssl.keystore.location = null

572 schema.registry.ssl.keystore.password = null

573 schema.registry.ssl.keystore.type = JKS

574 schema.registry.ssl.protocol = TLSv1.3

575 schema.registry.ssl.provider = null

576 schema.registry.ssl.secure.random.implementation = null

577 schema.registry.ssl.trustmanager.algorithm = PKIX

578 schema.registry.ssl.truststore.certificates = null

579 schema.registry.ssl.truststore.location = null

580 schema.registry.ssl.truststore.password = null

581 schema.registry.ssl.truststore.type = JKS

582 schema.registry.url = []

583 schema.registry.url.randomize = false

584 specific.avro.key.type = null

585 specific.avro.reader = false

586 specific.avro.value.type = null

587 use.latest.version = false

588 use.latest.with.metadata = null

589 use.schema.id = -1

590 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

591

59220:18:58.859 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

593 auto.register.schemas = true

594 avro.reflection.allow.null = false

595 avro.remove.java.properties = false

596 avro.use.logical.type.converters = false

597 basic.auth.credentials.source = URL

598 basic.auth.user.info = [hidden]

599 bearer.auth.cache.expiry.buffer.seconds = 300

600 bearer.auth.client.id = null

601 bearer.auth.client.secret = null

602 bearer.auth.credentials.source = STATIC_TOKEN

603 bearer.auth.custom.provider.class = null

604 bearer.auth.identity.pool.id = null

605 bearer.auth.issuer.endpoint.url = null

606 bearer.auth.logical.cluster = null

607 bearer.auth.scope = null

608 bearer.auth.scope.claim.name = scope

609 bearer.auth.sub.claim.name = sub

610 bearer.auth.token = [hidden]

611 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

612 http.connect.timeout.ms = 60000

613 http.read.timeout.ms = 60000

614 id.compatibility.strict = true

615 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

616 latest.cache.size = 1000

617 latest.cache.ttl.sec = -1

618 latest.compatibility.strict = true

619 max.retries = 3

620 max.schemas.per.subject = 1000

621 normalize.schemas = false

622 propagate.schema.tags = false

623 proxy.host =

624 proxy.port = -1

625 retries.max.wait.ms = 20000

626 retries.wait.ms = 1000

627 rule.actions = []

628 rule.executors = []

629 rule.service.loader.enable = true

630 schema.format = null

631 schema.reflection = false

632 schema.registry.basic.auth.user.info = [hidden]

633 schema.registry.ssl.cipher.suites = null

634 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

635 schema.registry.ssl.endpoint.identification.algorithm = https

636 schema.registry.ssl.engine.factory.class = null

637 schema.registry.ssl.key.password = null

638 schema.registry.ssl.keymanager.algorithm = SunX509

639 schema.registry.ssl.keystore.certificate.chain = null

640 schema.registry.ssl.keystore.key = null

641 schema.registry.ssl.keystore.location = null

642 schema.registry.ssl.keystore.password = null

643 schema.registry.ssl.keystore.type = JKS

644 schema.registry.ssl.protocol = TLSv1.3

645 schema.registry.ssl.provider = null

646 schema.registry.ssl.secure.random.implementation = null

647 schema.registry.ssl.trustmanager.algorithm = PKIX

648 schema.registry.ssl.truststore.certificates = null

649 schema.registry.ssl.truststore.location = null

650 schema.registry.ssl.truststore.password = null

651 schema.registry.ssl.truststore.type = JKS

652 schema.registry.url = []

653 schema.registry.url.randomize = false

654 use.latest.version = false

655 use.latest.with.metadata = null

656 use.schema.id = -1

657 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

658

659[info] - should be able to do roundtrip serialization using compatible schemas (16 milliseconds)

66020:18:58.874 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

661 auto.register.schemas = true

662 avro.reflection.allow.null = false

663 avro.remove.java.properties = false

664 avro.use.logical.type.converters = false

665 basic.auth.credentials.source = URL

666 basic.auth.user.info = [hidden]

667 bearer.auth.cache.expiry.buffer.seconds = 300

668 bearer.auth.client.id = null

669 bearer.auth.client.secret = null

670 bearer.auth.credentials.source = STATIC_TOKEN

671 bearer.auth.custom.provider.class = null

672 bearer.auth.identity.pool.id = null

673 bearer.auth.issuer.endpoint.url = null

674 bearer.auth.logical.cluster = null

675 bearer.auth.scope = null

676 bearer.auth.scope.claim.name = scope

677 bearer.auth.sub.claim.name = sub

678 bearer.auth.token = [hidden]

679 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

680 http.connect.timeout.ms = 60000

681 http.read.timeout.ms = 60000

682 id.compatibility.strict = true

683 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

684 latest.cache.size = 1000

685 latest.cache.ttl.sec = -1

686 latest.compatibility.strict = true

687 max.retries = 3

688 max.schemas.per.subject = 1000

689 normalize.schemas = false

690 propagate.schema.tags = false

691 proxy.host =

692 proxy.port = -1

693 retries.max.wait.ms = 20000

694 retries.wait.ms = 1000

695 rule.actions = []

696 rule.executors = []

697 rule.service.loader.enable = true

698 schema.format = null

699 schema.reflection = false

700 schema.registry.basic.auth.user.info = [hidden]

701 schema.registry.ssl.cipher.suites = null

702 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

703 schema.registry.ssl.endpoint.identification.algorithm = https

704 schema.registry.ssl.engine.factory.class = null

705 schema.registry.ssl.key.password = null

706 schema.registry.ssl.keymanager.algorithm = SunX509

707 schema.registry.ssl.keystore.certificate.chain = null

708 schema.registry.ssl.keystore.key = null

709 schema.registry.ssl.keystore.location = null

710 schema.registry.ssl.keystore.password = null

711 schema.registry.ssl.keystore.type = JKS

712 schema.registry.ssl.protocol = TLSv1.3

713 schema.registry.ssl.provider = null

714 schema.registry.ssl.secure.random.implementation = null

715 schema.registry.ssl.trustmanager.algorithm = PKIX

716 schema.registry.ssl.truststore.certificates = null

717 schema.registry.ssl.truststore.location = null

718 schema.registry.ssl.truststore.password = null

719 schema.registry.ssl.truststore.type = JKS

720 schema.registry.url = []

721 schema.registry.url.randomize = false

722 use.latest.version = false

723 use.latest.with.metadata = null

724 use.schema.id = -1

725 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

726

72720:18:58.874 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

728 auto.register.schemas = true

729 avro.reflection.allow.null = false

730 avro.use.logical.type.converters = false

731 basic.auth.credentials.source = URL

732 basic.auth.user.info = [hidden]

733 bearer.auth.cache.expiry.buffer.seconds = 300

734 bearer.auth.client.id = null

735 bearer.auth.client.secret = null

736 bearer.auth.credentials.source = STATIC_TOKEN

737 bearer.auth.custom.provider.class = null

738 bearer.auth.identity.pool.id = null

739 bearer.auth.issuer.endpoint.url = null

740 bearer.auth.logical.cluster = null

741 bearer.auth.scope = null

742 bearer.auth.scope.claim.name = scope

743 bearer.auth.sub.claim.name = sub

744 bearer.auth.token = [hidden]

745 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

746 http.connect.timeout.ms = 60000

747 http.read.timeout.ms = 60000

748 id.compatibility.strict = true

749 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

750 latest.cache.size = 1000

751 latest.cache.ttl.sec = -1

752 latest.compatibility.strict = true

753 max.retries = 3

754 max.schemas.per.subject = 1000

755 normalize.schemas = false

756 propagate.schema.tags = false

757 proxy.host =

758 proxy.port = -1

759 retries.max.wait.ms = 20000

760 retries.wait.ms = 1000

761 rule.actions = []

762 rule.executors = []

763 rule.service.loader.enable = true

764 schema.format = null

765 schema.reflection = false

766 schema.registry.basic.auth.user.info = [hidden]

767 schema.registry.ssl.cipher.suites = null

768 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

769 schema.registry.ssl.endpoint.identification.algorithm = https

770 schema.registry.ssl.engine.factory.class = null

771 schema.registry.ssl.key.password = null

772 schema.registry.ssl.keymanager.algorithm = SunX509

773 schema.registry.ssl.keystore.certificate.chain = null

774 schema.registry.ssl.keystore.key = null

775 schema.registry.ssl.keystore.location = null

776 schema.registry.ssl.keystore.password = null

777 schema.registry.ssl.keystore.type = JKS

778 schema.registry.ssl.protocol = TLSv1.3

779 schema.registry.ssl.provider = null

780 schema.registry.ssl.secure.random.implementation = null

781 schema.registry.ssl.trustmanager.algorithm = PKIX

782 schema.registry.ssl.truststore.certificates = null

783 schema.registry.ssl.truststore.location = null

784 schema.registry.ssl.truststore.password = null

785 schema.registry.ssl.truststore.type = JKS

786 schema.registry.url = []

787 schema.registry.url.randomize = false

788 specific.avro.key.type = null

789 specific.avro.reader = false

790 specific.avro.value.type = null

791 use.latest.version = false

792 use.latest.with.metadata = null

793 use.schema.id = -1

794 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

795

796[info] - should error when reader and writer schemas have mismatching logical types (23 milliseconds)

797[info] AvroSettingsSpec:

798[info] AvroSettings

799[info] - should provide withAutoRegisterSchemas (108 milliseconds)

800[info] - should provide withKeySubjectNameStrategy (11 milliseconds)

801[info] - should provide withValueSubjectNameStrategy (4 milliseconds)

802[info] - should provide withProperty (7 milliseconds)

803[info] - should provide withProperties (4 milliseconds)

804[info] - should provide withProperties(Map) (4 milliseconds)

805[info] - should provide withCreateAvroDeserializer (3 milliseconds)

806[info] - should provide withCreateAvroSerializer (3 milliseconds)

807[info] - should provide withRegisterSchema (1 millisecond)

808[info] - should provide toString (1 millisecond)

80920:18:59.088 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

810 auto.register.schemas = true

811 avro.reflection.allow.null = false

812 avro.remove.java.properties = false

813 avro.use.logical.type.converters = false

814 basic.auth.credentials.source = URL

815 basic.auth.user.info = [hidden]

816 bearer.auth.cache.expiry.buffer.seconds = 300

817 bearer.auth.client.id = null

818 bearer.auth.client.secret = null

819 bearer.auth.credentials.source = STATIC_TOKEN

820 bearer.auth.custom.provider.class = null

821 bearer.auth.identity.pool.id = null

822 bearer.auth.issuer.endpoint.url = null

823 bearer.auth.logical.cluster = null

824 bearer.auth.scope = null

825 bearer.auth.scope.claim.name = scope

826 bearer.auth.sub.claim.name = sub

827 bearer.auth.token = [hidden]

828 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

829 http.connect.timeout.ms = 60000

830 http.read.timeout.ms = 60000

831 id.compatibility.strict = true

832 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

833 latest.cache.size = 1000

834 latest.cache.ttl.sec = -1

835 latest.compatibility.strict = true

836 max.retries = 3

837 max.schemas.per.subject = 1000

838 normalize.schemas = false

839 propagate.schema.tags = false

840 proxy.host =

841 proxy.port = -1

842 retries.max.wait.ms = 20000

843 retries.wait.ms = 1000

844 rule.actions = []

845 rule.executors = []

846 rule.service.loader.enable = true

847 schema.format = null

848 schema.reflection = false

849 schema.registry.basic.auth.user.info = [hidden]

850 schema.registry.ssl.cipher.suites = null

851 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

852 schema.registry.ssl.endpoint.identification.algorithm = https

853 schema.registry.ssl.engine.factory.class = null

854 schema.registry.ssl.key.password = null

855 schema.registry.ssl.keymanager.algorithm = SunX509

856 schema.registry.ssl.keystore.certificate.chain = null

857 schema.registry.ssl.keystore.key = null

858 schema.registry.ssl.keystore.location = null

859 schema.registry.ssl.keystore.password = null

860 schema.registry.ssl.keystore.type = JKS

861 schema.registry.ssl.protocol = TLSv1.3

862 schema.registry.ssl.provider = null

863 schema.registry.ssl.secure.random.implementation = null

864 schema.registry.ssl.trustmanager.algorithm = PKIX

865 schema.registry.ssl.truststore.certificates = null

866 schema.registry.ssl.truststore.location = null

867 schema.registry.ssl.truststore.password = null

868 schema.registry.ssl.truststore.type = JKS

869 schema.registry.url = []

870 schema.registry.url.randomize = false

871 use.latest.version = false

872 use.latest.with.metadata = null

873 use.schema.id = -1

874 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

875

876[info] AvroSerializerSpec:

877[info] AvroSerializer

87820:18:59.092 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

879 auto.register.schemas = true

880 avro.reflection.allow.null = false

881 avro.remove.java.properties = false

882 avro.use.logical.type.converters = false

883 basic.auth.credentials.source = URL

884 basic.auth.user.info = [hidden]

885 bearer.auth.cache.expiry.buffer.seconds = 300

886 bearer.auth.client.id = null

887 bearer.auth.client.secret = null

888 bearer.auth.credentials.source = STATIC_TOKEN

889 bearer.auth.custom.provider.class = null

890 bearer.auth.identity.pool.id = null

891 bearer.auth.issuer.endpoint.url = null

892 bearer.auth.logical.cluster = null

893 bearer.auth.scope = null

894 bearer.auth.scope.claim.name = scope

895 bearer.auth.sub.claim.name = sub

896 bearer.auth.token = [hidden]

897 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

898 http.connect.timeout.ms = 60000

899 http.read.timeout.ms = 60000

900 id.compatibility.strict = true

901 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

902 latest.cache.size = 1000

903 latest.cache.ttl.sec = -1

904 latest.compatibility.strict = true

905 max.retries = 3

906 max.schemas.per.subject = 1000

907 normalize.schemas = false

908 propagate.schema.tags = false

909 proxy.host =

910 proxy.port = -1

911 retries.max.wait.ms = 20000

912 retries.wait.ms = 1000

913 rule.actions = []

914 rule.executors = []

915 rule.service.loader.enable = true

916 schema.format = null

917 schema.reflection = false

918 schema.registry.basic.auth.user.info = [hidden]

919 schema.registry.ssl.cipher.suites = null

920 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

921 schema.registry.ssl.endpoint.identification.algorithm = https

922 schema.registry.ssl.engine.factory.class = null

923 schema.registry.ssl.key.password = null

924 schema.registry.ssl.keymanager.algorithm = SunX509

925 schema.registry.ssl.keystore.certificate.chain = null

926 schema.registry.ssl.keystore.key = null

927 schema.registry.ssl.keystore.location = null

928 schema.registry.ssl.keystore.password = null

929 schema.registry.ssl.keystore.type = JKS

930 schema.registry.ssl.protocol = TLSv1.3

931 schema.registry.ssl.provider = null

932 schema.registry.ssl.secure.random.implementation = null

933 schema.registry.ssl.trustmanager.algorithm = PKIX

934 schema.registry.ssl.truststore.certificates = null

935 schema.registry.ssl.truststore.location = null

936 schema.registry.ssl.truststore.password = null

937 schema.registry.ssl.truststore.type = JKS

938 schema.registry.url = []

939 schema.registry.url.randomize = false

940 use.latest.version = false

941 use.latest.with.metadata = null

942 use.schema.id = -1

943 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

944

94520:18:59.098 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

946 auto.register.schemas = true

947 avro.reflection.allow.null = false

948 avro.remove.java.properties = false

949 avro.use.logical.type.converters = false

950 basic.auth.credentials.source = URL

951 basic.auth.user.info = [hidden]

952 bearer.auth.cache.expiry.buffer.seconds = 300

953 bearer.auth.client.id = null

954 bearer.auth.client.secret = null

955 bearer.auth.credentials.source = STATIC_TOKEN

956 bearer.auth.custom.provider.class = null

957 bearer.auth.identity.pool.id = null

958 bearer.auth.issuer.endpoint.url = null

959 bearer.auth.logical.cluster = null

960 bearer.auth.scope = null

961 bearer.auth.scope.claim.name = scope

962 bearer.auth.sub.claim.name = sub

963 bearer.auth.token = [hidden]

964 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

965 http.connect.timeout.ms = 60000

966 http.read.timeout.ms = 60000

967 id.compatibility.strict = true

968 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

969 latest.cache.size = 1000

970 latest.cache.ttl.sec = -1

971 latest.compatibility.strict = true

972 max.retries = 3

973 max.schemas.per.subject = 1000

974 normalize.schemas = false

975 propagate.schema.tags = false

976 proxy.host =

977 proxy.port = -1

978 retries.max.wait.ms = 20000

979 retries.wait.ms = 1000

980 rule.actions = []

981 rule.executors = []

982 rule.service.loader.enable = true

983 schema.format = null

984 schema.reflection = false

985 schema.registry.basic.auth.user.info = [hidden]

986 schema.registry.ssl.cipher.suites = null

987 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

988 schema.registry.ssl.endpoint.identification.algorithm = https

989 schema.registry.ssl.engine.factory.class = null

990 schema.registry.ssl.key.password = null

991 schema.registry.ssl.keymanager.algorithm = SunX509

992 schema.registry.ssl.keystore.certificate.chain = null

993 schema.registry.ssl.keystore.key = null

994 schema.registry.ssl.keystore.location = null

995 schema.registry.ssl.keystore.password = null

996 schema.registry.ssl.keystore.type = JKS

997 schema.registry.ssl.protocol = TLSv1.3

998 schema.registry.ssl.provider = null

999 schema.registry.ssl.secure.random.implementation = null

1000 schema.registry.ssl.trustmanager.algorithm = PKIX

1001 schema.registry.ssl.truststore.certificates = null

1002 schema.registry.ssl.truststore.location = null

1003 schema.registry.ssl.truststore.password = null

1004 schema.registry.ssl.truststore.type = JKS

1005 schema.registry.url = []

1006 schema.registry.url.randomize = false

1007 use.latest.version = false

1008 use.latest.with.metadata = null

1009 use.schema.id = -1

1010 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

1011

1012[info] - can create a serializer (9 milliseconds)

1013[info] - auto-registers union schemas (12 milliseconds)

1014[info] - raises schema errors (5 milliseconds)

1015[info] - toString (1 millisecond)

1016[info] AuthSpec:

1017[info] Auth.Basic

1018[info] - should include the username in toString (7 milliseconds)

1019[info] - should not include the password in toString (6 milliseconds)

1020[info] Auth.Bearer

1021[info] - should not include the token in toString (2 milliseconds)

1022[info] Auth.None

1023[info] - should have None as toString (3 milliseconds)

1024[info] SchemaRegistryClientSettingsSpec:

1025[info] SchemaRegistryClientSettings

1026[info] - should provide withMaxCacheSize (0 milliseconds)

1027[info] - should provide withAuth(Auth.Basic) (5 milliseconds)

1028[info] - should provide withAuth(Auth.Bearer) (3 milliseconds)

1029[info] - should provide withAuth(Auth.None) (1 millisecond)

1030[info] - should provide withProperty (3 milliseconds)

1031[info] - should provide withProperties (3 milliseconds)

1032[info] - should provide withProperties(Map) (3 milliseconds)

1033[info] - should provide withCreateSchemaRegistryClient (2 milliseconds)

1034[info] - should provide toString (3 milliseconds)

1035[info] - should provide Show (0 milliseconds)

103620:18:59.207 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

1037 auto.register.schemas = true

1038 avro.reflection.allow.null = false

1039 avro.use.logical.type.converters = false

1040 basic.auth.credentials.source = URL

1041 basic.auth.user.info = [hidden]

1042 bearer.auth.cache.expiry.buffer.seconds = 300

1043 bearer.auth.client.id = null

1044 bearer.auth.client.secret = null

1045 bearer.auth.credentials.source = STATIC_TOKEN

1046 bearer.auth.custom.provider.class = null

1047 bearer.auth.identity.pool.id = null

1048 bearer.auth.issuer.endpoint.url = null

1049 bearer.auth.logical.cluster = null

1050 bearer.auth.scope = null

1051 bearer.auth.scope.claim.name = scope

1052 bearer.auth.sub.claim.name = sub

1053 bearer.auth.token = [hidden]

1054 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

1055 http.connect.timeout.ms = 60000

1056 http.read.timeout.ms = 60000

1057 id.compatibility.strict = true

1058 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

1059 latest.cache.size = 1000

1060 latest.cache.ttl.sec = -1

1061 latest.compatibility.strict = true

1062 max.retries = 3

1063 max.schemas.per.subject = 1000

1064 normalize.schemas = false

1065 propagate.schema.tags = false

1066 proxy.host =

1067 proxy.port = -1

1068 retries.max.wait.ms = 20000

1069 retries.wait.ms = 1000

1070 rule.actions = []

1071 rule.executors = []

1072 rule.service.loader.enable = true

1073 schema.format = null

1074 schema.reflection = false

1075 schema.registry.basic.auth.user.info = [hidden]

1076 schema.registry.ssl.cipher.suites = null

1077 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

1078 schema.registry.ssl.endpoint.identification.algorithm = https

1079 schema.registry.ssl.engine.factory.class = null

1080 schema.registry.ssl.key.password = null

1081 schema.registry.ssl.keymanager.algorithm = SunX509

1082 schema.registry.ssl.keystore.certificate.chain = null

1083 schema.registry.ssl.keystore.key = null

1084 schema.registry.ssl.keystore.location = null

1085 schema.registry.ssl.keystore.password = null

1086 schema.registry.ssl.keystore.type = JKS

1087 schema.registry.ssl.protocol = TLSv1.3

1088 schema.registry.ssl.provider = null

1089 schema.registry.ssl.secure.random.implementation = null

1090 schema.registry.ssl.trustmanager.algorithm = PKIX

1091 schema.registry.ssl.truststore.certificates = null

1092 schema.registry.ssl.truststore.location = null

1093 schema.registry.ssl.truststore.password = null

1094 schema.registry.ssl.truststore.type = JKS

1095 schema.registry.url = []

1096 schema.registry.url.randomize = false

1097 specific.avro.key.type = null

1098 specific.avro.reader = false

1099 specific.avro.value.type = null

1100 use.latest.version = false

1101 use.latest.with.metadata = null

1102 use.schema.id = -1

1103 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

1104

110520:18:59.214 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

1106 auto.register.schemas = true

1107 avro.reflection.allow.null = false

1108 avro.use.logical.type.converters = false

1109 basic.auth.credentials.source = URL

1110 basic.auth.user.info = [hidden]

1111 bearer.auth.cache.expiry.buffer.seconds = 300

1112 bearer.auth.client.id = null

1113 bearer.auth.client.secret = null

1114 bearer.auth.credentials.source = STATIC_TOKEN

1115 bearer.auth.custom.provider.class = null

1116 bearer.auth.identity.pool.id = null

1117 bearer.auth.issuer.endpoint.url = null

1118 bearer.auth.logical.cluster = null

1119 bearer.auth.scope = null

1120 bearer.auth.scope.claim.name = scope

1121 bearer.auth.sub.claim.name = sub

1122 bearer.auth.token = [hidden]

1123 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

1124 http.connect.timeout.ms = 60000

1125 http.read.timeout.ms = 60000

1126 id.compatibility.strict = true

1127 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

1128 latest.cache.size = 1000

1129 latest.cache.ttl.sec = -1

1130 latest.compatibility.strict = true

1131 max.retries = 3

1132 max.schemas.per.subject = 1000

1133 normalize.schemas = false

1134 propagate.schema.tags = false

1135 proxy.host =

1136 proxy.port = -1

1137 retries.max.wait.ms = 20000

1138 retries.wait.ms = 1000

1139 rule.actions = []

1140 rule.executors = []

1141 rule.service.loader.enable = true

1142 schema.format = null

1143 schema.reflection = false

1144 schema.registry.basic.auth.user.info = [hidden]

1145 schema.registry.ssl.cipher.suites = null

1146 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

1147 schema.registry.ssl.endpoint.identification.algorithm = https

1148 schema.registry.ssl.engine.factory.class = null

1149 schema.registry.ssl.key.password = null

1150 schema.registry.ssl.keymanager.algorithm = SunX509

1151 schema.registry.ssl.keystore.certificate.chain = null

1152 schema.registry.ssl.keystore.key = null

1153 schema.registry.ssl.keystore.location = null

1154 schema.registry.ssl.keystore.password = null

1155 schema.registry.ssl.keystore.type = JKS

1156 schema.registry.ssl.protocol = TLSv1.3

1157 schema.registry.ssl.provider = null

1158 schema.registry.ssl.secure.random.implementation = null

1159 schema.registry.ssl.trustmanager.algorithm = PKIX

1160 schema.registry.ssl.truststore.certificates = null

1161 schema.registry.ssl.truststore.location = null

1162 schema.registry.ssl.truststore.password = null

1163 schema.registry.ssl.truststore.type = JKS

1164 schema.registry.url = []

1165 schema.registry.url.randomize = false

1166 specific.avro.key.type = null

1167 specific.avro.reader = false

1168 specific.avro.value.type = null

1169 use.latest.version = false

1170 use.latest.with.metadata = null

1171 use.schema.id = -1

1172 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

1173

1174[info] AvroDeserializerSpec:

1175[info] AvroDeserializer

1176[info] - can create a deserializer (11 milliseconds)

1177[info] - raises schema errors (6 milliseconds)

117820:18:59.230 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

1179 auto.register.schemas = true

1180 avro.reflection.allow.null = false

1181 avro.use.logical.type.converters = false

1182 basic.auth.credentials.source = URL

1183 basic.auth.user.info = [hidden]

1184 bearer.auth.cache.expiry.buffer.seconds = 300

1185 bearer.auth.client.id = null

1186 bearer.auth.client.secret = null

1187 bearer.auth.credentials.source = STATIC_TOKEN

1188 bearer.auth.custom.provider.class = null

1189 bearer.auth.identity.pool.id = null

1190 bearer.auth.issuer.endpoint.url = null

1191 bearer.auth.logical.cluster = null

1192 bearer.auth.scope = null

1193 bearer.auth.scope.claim.name = scope

1194 bearer.auth.sub.claim.name = sub

1195 bearer.auth.token = [hidden]

1196 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

1197 http.connect.timeout.ms = 60000

1198 http.read.timeout.ms = 60000

1199 id.compatibility.strict = true

1200 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

1201 latest.cache.size = 1000

1202 latest.cache.ttl.sec = -1

1203 latest.compatibility.strict = true

1204 max.retries = 3

1205 max.schemas.per.subject = 1000

1206 normalize.schemas = false

1207 propagate.schema.tags = false

1208 proxy.host =

1209 proxy.port = -1

1210 retries.max.wait.ms = 20000

1211 retries.wait.ms = 1000

1212 rule.actions = []

1213 rule.executors = []

1214 rule.service.loader.enable = true

1215 schema.format = null

1216 schema.reflection = false

1217 schema.registry.basic.auth.user.info = [hidden]

1218 schema.registry.ssl.cipher.suites = null

1219 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

1220 schema.registry.ssl.endpoint.identification.algorithm = https

1221 schema.registry.ssl.engine.factory.class = null

1222 schema.registry.ssl.key.password = null

1223 schema.registry.ssl.keymanager.algorithm = SunX509

1224 schema.registry.ssl.keystore.certificate.chain = null

1225 schema.registry.ssl.keystore.key = null

1226 schema.registry.ssl.keystore.location = null

1227 schema.registry.ssl.keystore.password = null

1228 schema.registry.ssl.keystore.type = JKS

1229 schema.registry.ssl.protocol = TLSv1.3

1230 schema.registry.ssl.provider = null

1231 schema.registry.ssl.secure.random.implementation = null

1232 schema.registry.ssl.trustmanager.algorithm = PKIX

1233 schema.registry.ssl.truststore.certificates = null

1234 schema.registry.ssl.truststore.location = null

1235 schema.registry.ssl.truststore.password = null

1236 schema.registry.ssl.truststore.type = JKS

1237 schema.registry.url = []

1238 schema.registry.url.randomize = false

1239 specific.avro.key.type = null

1240 specific.avro.reader = false

1241 specific.avro.value.type = null

1242 use.latest.version = false

1243 use.latest.with.metadata = null

1244 use.schema.id = -1

1245 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

1246

1247[info] - raises IllegalArgumentException if the data is null (11 milliseconds)

1248[info] - toString (1 millisecond)

1249Starting build for ProjectRef(file:/build/repo/,vulcan-testkit-munit) (fs2-kafka-vulcan-testkit-munit)... [2/4]

1250Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

1251[info] compiling 1 Scala source to /build/repo/modules/vulcan-testkit-munit/target/scala-3.8.1-RC1/classes ...

1252[info] done compiling

1253Starting build for ProjectRef(file:/build/repo/,core) (fs2-kafka)... [3/4]

1254Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

1255[info] compiling 42 Scala sources to /build/repo/modules/core/target/scala-3.8.1-RC1/test-classes ...

1256[info] done compiling

1257[info] TimestampLawsSpec:

1258[info] - Timestamp.eqLaws.eq.antisymmetry eq (68 milliseconds)

1259[info] - Timestamp.eqLaws.eq.reflexivity eq (7 milliseconds)

1260[info] - Timestamp.eqLaws.eq.symmetry eq (13 milliseconds)

1261[info] - Timestamp.eqLaws.eq.transitivity eq (7 milliseconds)

1262[info] UnexpectedTopicExceptionSpec:

1263[info] UnexpectedTopicException

1264[info] - should have expected message and toString (9 milliseconds)

1265[info] IsolationLevelSpec:

1266[info] IsolationLevel

1267[info] - should have toString matching name (2 milliseconds)

1268[info] JitterSpec:

1269[info] Jitter#default

1270[info] - should always apply jitter on values (259 milliseconds)

1271[info] Jitter#none

1272[info] - should never apply jitter on values (2 milliseconds)

1273[info] SerializationExceptionSpec:

1274[info] SerializationException

1275[info] - should have expected message and toString (2 milliseconds)

1276[info] ConsumerRecordLawsSpec:

1277[info] - ConsumerRecord.eqLaws.eq.antisymmetry eq (79 milliseconds)

1278[info] - ConsumerRecord.eqLaws.eq.reflexivity eq (14 milliseconds)

1279[info] - ConsumerRecord.eqLaws.eq.symmetry eq (20 milliseconds)

1280[info] - ConsumerRecord.eqLaws.eq.transitivity eq (29 milliseconds)

1281[info] - ConsumerRecord.traverseLaws.traverse.collectFirst reference (23 milliseconds)

1282[info] - ConsumerRecord.traverseLaws.traverse.collectFirstSome reference (11 milliseconds)

1283[info] - ConsumerRecord.traverseLaws.traverse.contains all elements from itself (10 milliseconds)

1284[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with exists (11 milliseconds)

1285[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with forall (14 milliseconds)

1286[info] - ConsumerRecord.traverseLaws.traverse.covariant composition (8 milliseconds)

1287[info] - ConsumerRecord.traverseLaws.traverse.covariant identity (10 milliseconds)

1288[info] - ConsumerRecord.traverseLaws.traverse.dropWhile_ reference (9 milliseconds)

1289[info] - ConsumerRecord.traverseLaws.traverse.exists consistent with find (7 milliseconds)

1290[info] - ConsumerRecord.traverseLaws.traverse.exists is lazy (9 milliseconds)

1291[info] - ConsumerRecord.traverseLaws.traverse.filter_ reference (9 milliseconds)

1292[info] - ConsumerRecord.traverseLaws.traverse.fold reference (7 milliseconds)

1293[info] - ConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (11 milliseconds)

1294[info] - ConsumerRecord.traverseLaws.traverse.foldM identity (15 milliseconds)

1295[info] - ConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (10 milliseconds)

1296[info] - ConsumerRecord.traverseLaws.traverse.foldRight is lazy (5 milliseconds)

1297[info] - ConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (9 milliseconds)

1298[info] - ConsumerRecord.traverseLaws.traverse.forall consistent with exists (6 milliseconds)

1299[info] - ConsumerRecord.traverseLaws.traverse.forall is lazy (4 milliseconds)

1300[info] - ConsumerRecord.traverseLaws.traverse.forall true if empty (4 milliseconds)

1301[info] - ConsumerRecord.traverseLaws.traverse.get reference (12 milliseconds)

1302[info] - ConsumerRecord.traverseLaws.traverse.invariant composition (9 milliseconds)

1303[info] - ConsumerRecord.traverseLaws.traverse.invariant identity (5 milliseconds)

1304[info] - ConsumerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (6 milliseconds)

1305[info] - ConsumerRecord.traverseLaws.traverse.nonEmpty reference (4 milliseconds)

1306[info] - ConsumerRecord.traverseLaws.traverse.ordered consistency (5 milliseconds)

1307[info] - ConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (4 milliseconds)

1308[info] - ConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (8 milliseconds)

1309[info] - ConsumerRecord.traverseLaws.traverse.takeWhile_ reference (9 milliseconds)

1310[info] - ConsumerRecord.traverseLaws.traverse.toList reference (5 milliseconds)

1311[info] - ConsumerRecord.traverseLaws.traverse.traverse derive foldMap (14 milliseconds)

1312[info] - ConsumerRecord.traverseLaws.traverse.traverse identity (5 milliseconds)

1313[info] - ConsumerRecord.traverseLaws.traverse.traverse order consistency (7 milliseconds)

1314[info] - ConsumerRecord.traverseLaws.traverse.traverse parallel composition (9 milliseconds)

1315[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (32 milliseconds)

1316[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (7 milliseconds)

1317[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (7 milliseconds)

1318[info] - ConsumerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (6 milliseconds)

1319[info] - ConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (6 milliseconds)

1320[info] - ConsumerRecord.traverseLaws.traverse.traverse ref updated (5 milliseconds)

1321[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (7 milliseconds)

1322[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (8 milliseconds)

1323[info] - ConsumerRecord.traverseLaws.traverse.traverse sequential composition (17 milliseconds)

1324[info] - ConsumerRecord.traverseLaws.traverse.traverse traverseTap (5 milliseconds)

1325[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (4 milliseconds)

1326[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (8 milliseconds)

1327[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (10 milliseconds)

1328[info] - ConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (4 milliseconds)

1329[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (7 milliseconds)

1330[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (6 milliseconds)

1331[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (4 milliseconds)

1332[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (3 milliseconds)

1333[info] - ConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (5 milliseconds)

1334[info] - ConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (7 milliseconds)

1335[info] - ConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (10 milliseconds)

1336[info] - ConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 milliseconds)

1337[info] CommitTimeoutExceptionSpec:

1338[info] CommitTimeoutException

1339[info] - should have expected message and toString (18 milliseconds)

1340[info] TimestampSpec:

1341[info] Timeout#createTime

1342[info] - should have a createTime (4 milliseconds)

1343[info] - should not have a logAppendTime (1 millisecond)

1344[info] - should not have an unknownTime (1 millisecond)

1345[info] - should include the createTime in toString (5 milliseconds)

1346[info] Timeout#logAppendTime

1347[info] - should have a logAppendTime (1 millisecond)

1348[info] - should not have a createTime (0 milliseconds)

1349[info] - should not have an unknownTime (1 millisecond)

1350[info] - should include the logAppendTime in toString (2 milliseconds)

1351[info] Timeout#unknownTime

1352[info] - should not have a logAppendTime (2 milliseconds)

1353[info] - should not have a createTime (1 millisecond)

1354[info] - should have an unknownTime (1 millisecond)

1355[info] - should include the unknownTime in toString (1 millisecond)

1356[info] Timestamp#none

1357[info] - should not have createTime (0 milliseconds)

1358[info] - should not have logAppendTime (1 millisecond)

1359[info] - should not have unknownTime (1 millisecond)

1360[info] - should be empty (0 milliseconds)

1361[info] - should not include any time in toString (1 millisecond)

1362[info] CommittableConsumerRecordSpec:

1363[info] CommittableConsumerRecord

1364[info] - should have a Show instance and matching toString (4 milliseconds)

1365[info] KafkaSpec:

1366[info] commitBatchWithin

1367[info] - should batch commit according specified arguments (140 milliseconds)

1368[info] ProducerRecordLawsSpec:

1369[info] - ProducerRecord.eqLaws.eq.antisymmetry eq (5 milliseconds)

1370[info] - ProducerRecord.eqLaws.eq.reflexivity eq (3 milliseconds)

1371[info] - ProducerRecord.eqLaws.eq.symmetry eq (5 milliseconds)

1372[info] - ProducerRecord.eqLaws.eq.transitivity eq (8 milliseconds)

1373[info] - ProducerRecord.traverseLaws.traverse.collectFirst reference (4 milliseconds)

1374[info] - ProducerRecord.traverseLaws.traverse.collectFirstSome reference (6 milliseconds)

1375[info] - ProducerRecord.traverseLaws.traverse.contains all elements from itself (5 milliseconds)

1376[info] - ProducerRecord.traverseLaws.traverse.contains consistent with exists (6 milliseconds)

1377[info] - ProducerRecord.traverseLaws.traverse.contains consistent with forall (6 milliseconds)

1378[info] - ProducerRecord.traverseLaws.traverse.covariant composition (6 milliseconds)

1379[info] - ProducerRecord.traverseLaws.traverse.covariant identity (4 milliseconds)

1380[info] - ProducerRecord.traverseLaws.traverse.dropWhile_ reference (5 milliseconds)

1381[info] - ProducerRecord.traverseLaws.traverse.exists consistent with find (3 milliseconds)

1382[info] - ProducerRecord.traverseLaws.traverse.exists is lazy (2 milliseconds)

1383[info] - ProducerRecord.traverseLaws.traverse.filter_ reference (2 milliseconds)

1384[info] - ProducerRecord.traverseLaws.traverse.fold reference (3 milliseconds)

1385[info] - ProducerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (4 milliseconds)

1386[info] - ProducerRecord.traverseLaws.traverse.foldM identity (4 milliseconds)

1387[info] - ProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (5 milliseconds)

1388[info] - ProducerRecord.traverseLaws.traverse.foldRight is lazy (3 milliseconds)

1389[info] - ProducerRecord.traverseLaws.traverse.foldRightDefer consistency (6 milliseconds)

1390[info] - ProducerRecord.traverseLaws.traverse.forall consistent with exists (5 milliseconds)

1391[info] - ProducerRecord.traverseLaws.traverse.forall is lazy (4 milliseconds)

1392[info] - ProducerRecord.traverseLaws.traverse.forall true if empty (3 milliseconds)

1393[info] - ProducerRecord.traverseLaws.traverse.get reference (4 milliseconds)

1394[info] - ProducerRecord.traverseLaws.traverse.invariant composition (5 milliseconds)

1395[info] - ProducerRecord.traverseLaws.traverse.invariant identity (3 milliseconds)

1396[info] - ProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (7 milliseconds)

1397[info] - ProducerRecord.traverseLaws.traverse.nonEmpty reference (2 milliseconds)

1398[info] - ProducerRecord.traverseLaws.traverse.ordered consistency (3 milliseconds)

1399[info] - ProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (3 milliseconds)

1400[info] - ProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (4 milliseconds)

1401[info] - ProducerRecord.traverseLaws.traverse.takeWhile_ reference (3 milliseconds)

1402[info] - ProducerRecord.traverseLaws.traverse.toList reference (3 milliseconds)

1403[info] - ProducerRecord.traverseLaws.traverse.traverse derive foldMap (5 milliseconds)

1404[info] - ProducerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

1405[info] - ProducerRecord.traverseLaws.traverse.traverse order consistency (6 milliseconds)

1406[info] - ProducerRecord.traverseLaws.traverse.traverse parallel composition (6 milliseconds)

1407[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (5 milliseconds)

1408[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (5 milliseconds)

1409[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (5 milliseconds)

1410[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (7 milliseconds)

1411[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (4 milliseconds)

1412[info] - ProducerRecord.traverseLaws.traverse.traverse ref updated (6 milliseconds)

1413[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (12 milliseconds)

1414[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (3 milliseconds)

1415[info] - ProducerRecord.traverseLaws.traverse.traverse sequential composition (3 milliseconds)

1416[info] - ProducerRecord.traverseLaws.traverse.traverse traverseTap (3 milliseconds)

1417[info] - ProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (5 milliseconds)

1418[info] - ProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (6 milliseconds)

1419[info] - ProducerRecord.traverseLaws.traverse.unordered traverse sequential composition (7 milliseconds)

1420[info] - ProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (4 milliseconds)

1421[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (3 milliseconds)

1422[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (4 milliseconds)

1423[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (3 milliseconds)

1424[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (4 milliseconds)

1425[info] - ProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (4 milliseconds)

1426[info] - ProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (5 milliseconds)

1427[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (4 milliseconds)

1428[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 milliseconds)

1429[info] AutoOffsetResetSpec:

1430[info] AutoOffsetReset

1431[info] - should have toString matching name (2 milliseconds)

1432[info] ConsumerSettingsSpec:

1433[info] ConsumerSettings

1434[info] - should be able to set a custom blocking context (5 milliseconds)

1435[info] - should provide withBootstrapServers (1 millisecond)

1436[info] - should provide withAutoOffsetReset (0 milliseconds)

1437[info] - should provide withAllowAutoCreateTopics (1 millisecond)

1438[info] - should provide withClientRack (1 millisecond)

1439[info] - should provide withClientId (1 millisecond)

1440[info] - should provide withGroupId (1 millisecond)

1441[info] - should provide withGroupInstanceId (0 milliseconds)

1442[info] - should provide withMaxPollRecords (0 milliseconds)

1443[info] - should provide withMaxPollInterval (0 milliseconds)

1444[info] - should provide withSessionTimeout (0 milliseconds)

1445[info] - should provide withHeartbeatInterval (0 milliseconds)

1446[info] - should provide withEnableAutoCommit (1 millisecond)

1447[info] - should provide withAutoCommitInterval (0 milliseconds)

1448[info] - should provide withRequestTimeout (0 milliseconds)

1449[info] - should provide withDefaultApiTimeout (0 milliseconds)

1450[info] - should provide withIsolationLevel (2 milliseconds)

1451[info] - should provide withProperty (0 milliseconds)

1452[info] - should provide withProperties (0 milliseconds)

1453[info] - should provide withCloseTimeout (0 milliseconds)

1454[info] - should provide withCommitTimeout (0 milliseconds)

1455[info] - should provide withPollInterval (0 milliseconds)

1456[info] - should provide withPollTimeout (1 millisecond)

1457[info] - should provide withCommitRecovery (0 milliseconds)

1458[info] - should provide withRecordMetadata (2 milliseconds)

1459[info] - should provide withMaxPrefetchBatches (0 milliseconds)

1460[info] - should be able to create with and without deserializer creation effects (1 millisecond)

1461[info] - should be able to implicitly create with and without deserializer creation effects (4 milliseconds)

1462[info] - should have a Show instance and matching toString (7 milliseconds)

1463[info] ConsumerShutdownExceptionSpec:

1464[info] ConsumerShutdownException

1465[info] - should have expected message and toString (2 milliseconds)

1466[info] HeaderSerializerSpec:

1467[info] - HeaderSerializer.contravariant.contravariant composition (85 milliseconds)

1468[info] - HeaderSerializer.contravariant.contravariant identity (46 milliseconds)

1469[info] - HeaderSerializer.contravariant.invariant composition (49 milliseconds)

1470[info] - HeaderSerializer.contravariant.invariant identity (35 milliseconds)

1471[info] - HeaderSerializer#mapBytes (6 milliseconds)

1472[info] - HeaderSerializer#const (1 millisecond)

1473[info] - HeaderSerializer#asNull (3 milliseconds)

1474[info] - HeaderSerializer#empty (3 milliseconds)

1475[info] - HeaderSerializer#option (7 milliseconds)

1476[info] - HeaderSerializer#unit (0 milliseconds)

1477[info] - HeaderSerializer#toString (1 millisecond)

1478[info] - HeaderSerializer#string (6 milliseconds)

1479[info] - HeaderSerializer#uuid (7 milliseconds)

1480[info] - HeaderSerializer#double (1 millisecond)

1481[info] - HeaderSerializer#float (4 milliseconds)

1482[info] - HeaderSerializer#int (2 milliseconds)

1483[info] - HeaderSerializer#long (1 millisecond)

1484[info] - HeaderSerializer#short (3 milliseconds)

1485[info] HeadersLawsSpec:

1486[info] - Headers.eqLaws.eq.antisymmetry eq (4 milliseconds)

1487[info] - Headers.eqLaws.eq.reflexivity eq (2 milliseconds)

1488[info] - Headers.eqLaws.eq.symmetry eq (3 milliseconds)

1489[info] - Headers.eqLaws.eq.transitivity eq (4 milliseconds)

1490[info] CommittableOffsetBatchSpec:

1491[info] CommittableOffsetBatch#empty

1492[info] - should have no offsets (0 milliseconds)

1493[info] - should return updated offset as batch (3 milliseconds)

1494[info] CommittableOffsetBatch#updated

1495[info] - should include the provided offset (14 milliseconds)

1496[info] - should override using the provided offset (23 milliseconds)

1497[info] - should be able to update with batch (11 milliseconds)

1498[info] CommittableOffsetBatch#toString

1499[info] - should provide a Show instance and matching toString (3 milliseconds)

1500[info] ProducerSettingsSpec:

1501[info] ProducerSettings

1502[info] - should provide apply (1 millisecond)

1503[info] - should provide withBootstrapServers (1 millisecond)

1504[info] - should provide withAcks (1 millisecond)

1505[info] - should provide withBatchSize (0 milliseconds)

1506[info] - should provide withClientId (1 millisecond)

1507[info] - should provide withRetries (0 milliseconds)

1508[info] - should provide withMaxInFlightRequestsPerConnection (1 millisecond)

1509[info] - should provide withEnableIdempotence (0 milliseconds)

1510[info] - should provide withLinger (0 milliseconds)

1511[info] - should provide withRequestTimeout (0 milliseconds)

1512[info] - should provide withDeliveryTimeout (0 milliseconds)

1513[info] - should provide withProperty/withProperties (1 millisecond)

1514[info] - should provide withCloseTimeout (1 millisecond)

1515[info] - should have a Show instance and matching toString (1 millisecond)

1516[info] - should be able to create with and without serializer creation effects (0 milliseconds)

1517[info] - should be able to implicitly create with and without serializer creation effects (2 milliseconds)

1518[info] - should be able to set a custom blocking context (3 milliseconds)

1519[info] - should provide failFastProduce default value (2 milliseconds)

1520[info] - should be able to set failFastProduce (1 millisecond)

1521[info] ConsumerRecordSpec:

1522[info] ConsumerRecord#fromJava

1523[info] - should convert timestamps (10 milliseconds)

1524[info] - should convert serialized key size (1 millisecond)

1525[info] - should convert serialized value size (2 milliseconds)

1526[info] - should convert leader epoch (2 milliseconds)

1527[info] ConsumerRecord#toString

1528[info] - should include headers when present (1 millisecond)

1529[info] - should include timestamp if present (0 milliseconds)

1530[info] - should include serialized key size if present (0 milliseconds)

1531[info] - should include serialized value size if present (1 millisecond)

1532[info] - should include leader epoch if present (0 milliseconds)

1533[info] AcksSpec:

1534[info] Acks

1535[info] - should have toString matching name (0 milliseconds)

1536[info] CommitRecoverySpec:

1537[info] CommitRecovery#Default

1538[info] - should retry org.apache.kafka.clients.consumer.RetriableCommitFailedException: retriable with jittered exponential backoff and fixed rate (14 milliseconds)

1539[info] - should retry org.apache.kafka.common.errors.RebalanceInProgressException with jittered exponential backoff and fixed rate (1 millisecond)

1540[info] - should not recover non-retriable exceptions (1 millisecond)

1541[info] - should have Default as String representation (0 milliseconds)

1542[info] CommitRecovery#None

1543[info] - should not recover any exceptions (3 milliseconds)

1544[info] - should have None as String representation (1 millisecond)

1545[info] CommittableOffsetLawsSpec:

1546[info] - CommittableOffset.eqLaws.eq.antisymmetry eq (2 milliseconds)

1547[info] - CommittableOffset.eqLaws.eq.reflexivity eq (1 millisecond)

1548[info] - CommittableOffset.eqLaws.eq.symmetry eq (2 milliseconds)

1549[info] - CommittableOffset.eqLaws.eq.transitivity eq (2 milliseconds)

1550[info] CommittableProducerRecordsLawsSpec:

1551[info] - CommittableProducerRecord.eqLaws.eq.antisymmetry eq (5 milliseconds)

1552[info] - CommittableProducerRecord.eqLaws.eq.reflexivity eq (4 milliseconds)

1553[info] - CommittableProducerRecord.eqLaws.eq.symmetry eq (5 milliseconds)

1554[info] - CommittableProducerRecord.eqLaws.eq.transitivity eq (7 milliseconds)

1555[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirst reference (5 milliseconds)

1556[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirstSome reference (5 milliseconds)

1557[info] - CommittableProducerRecord.traverseLaws.traverse.contains all elements from itself (5 milliseconds)

1558[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with exists (5 milliseconds)

1559[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with forall (4 milliseconds)

1560[info] - CommittableProducerRecord.traverseLaws.traverse.covariant composition (15 milliseconds)

1561[info] - CommittableProducerRecord.traverseLaws.traverse.covariant identity (5 milliseconds)

1562[info] - CommittableProducerRecord.traverseLaws.traverse.dropWhile_ reference (4 milliseconds)

1563[info] - CommittableProducerRecord.traverseLaws.traverse.exists consistent with find (4 milliseconds)

1564[info] - CommittableProducerRecord.traverseLaws.traverse.exists is lazy (4 milliseconds)

1565[info] - CommittableProducerRecord.traverseLaws.traverse.filter_ reference (4 milliseconds)

1566[info] - CommittableProducerRecord.traverseLaws.traverse.fold reference (4 milliseconds)

1567[info] - CommittableProducerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (6 milliseconds)

1568[info] - CommittableProducerRecord.traverseLaws.traverse.foldM identity (7 milliseconds)

1569[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (10 milliseconds)

1570[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight is lazy (4 milliseconds)

1571[info] - CommittableProducerRecord.traverseLaws.traverse.foldRightDefer consistency (5 milliseconds)

1572[info] - CommittableProducerRecord.traverseLaws.traverse.forall consistent with exists (4 milliseconds)

1573[info] - CommittableProducerRecord.traverseLaws.traverse.forall is lazy (3 milliseconds)

1574[info] - CommittableProducerRecord.traverseLaws.traverse.forall true if empty (4 milliseconds)

1575[info] - CommittableProducerRecord.traverseLaws.traverse.get reference (4 milliseconds)

1576[info] - CommittableProducerRecord.traverseLaws.traverse.invariant composition (6 milliseconds)

1577[info] - CommittableProducerRecord.traverseLaws.traverse.invariant identity (9 milliseconds)

1578[info] - CommittableProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (5 milliseconds)

1579[info] - CommittableProducerRecord.traverseLaws.traverse.nonEmpty reference (4 milliseconds)

1580[info] - CommittableProducerRecord.traverseLaws.traverse.ordered consistency (6 milliseconds)

1581[info] - CommittableProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (5 milliseconds)

1582[info] - CommittableProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (5 milliseconds)

1583[info] - CommittableProducerRecord.traverseLaws.traverse.takeWhile_ reference (5 milliseconds)

1584[info] - CommittableProducerRecord.traverseLaws.traverse.toList reference (3 milliseconds)

1585[info] - CommittableProducerRecord.traverseLaws.traverse.traverse derive foldMap (14 milliseconds)

1586[info] - CommittableProducerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

1587[info] - CommittableProducerRecord.traverseLaws.traverse.traverse order consistency (5 milliseconds)

1588[info] - CommittableProducerRecord.traverseLaws.traverse.traverse parallel composition (5 milliseconds)

1589[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (10 milliseconds)

1590[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (6 milliseconds)

1591[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (5 milliseconds)

1592[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (4 milliseconds)

1593[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (4 milliseconds)

1594[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref updated (4 milliseconds)

1595[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (5 milliseconds)

1596[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (5 milliseconds)

1597[info] - CommittableProducerRecord.traverseLaws.traverse.traverse sequential composition (4 milliseconds)

1598[info] - CommittableProducerRecord.traverseLaws.traverse.traverse traverseTap (5 milliseconds)

1599[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (3 milliseconds)

1600[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (5 milliseconds)

1601[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse sequential composition (5 milliseconds)

1602[info] - CommittableProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (3 milliseconds)

1603[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (4 milliseconds)

1604[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (5 milliseconds)

1605[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (2 milliseconds)

1606[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (6 milliseconds)

1607[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (5 milliseconds)

1608[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (4 milliseconds)

1609[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (4 milliseconds)

1610[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (6 milliseconds)

1611[info] HeaderDeserializerSpec:

1612[info] - HeaderDeserializer.monad.ap consistent with product + map (53 milliseconds)

1613[info] - HeaderDeserializer.monad.applicative homomorphism (31 milliseconds)

1614[info] - HeaderDeserializer.monad.applicative identity (38 milliseconds)

1615[info] - HeaderDeserializer.monad.applicative interchange (34 milliseconds)

1616[info] - HeaderDeserializer.monad.applicative map (35 milliseconds)

1617[info] - HeaderDeserializer.monad.applicative unit (28 milliseconds)

1618[info] - HeaderDeserializer.monad.apply composition (37 milliseconds)

1619[info] - HeaderDeserializer.monad.covariant composition (38 milliseconds)

1620[info] - HeaderDeserializer.monad.covariant identity (24 milliseconds)

1621[info] - HeaderDeserializer.monad.flatMap associativity (32 milliseconds)

1622[info] - HeaderDeserializer.monad.flatMap consistent apply (37 milliseconds)

1623[info] - HeaderDeserializer.monad.flatMap from tailRecM consistency (31 milliseconds)

1624[info] - HeaderDeserializer.monad.invariant composition (27 milliseconds)

1625[info] - HeaderDeserializer.monad.invariant identity (28 milliseconds)

1626[info] - HeaderDeserializer.monad.map flatMap coherence (26 milliseconds)

1627[info] - HeaderDeserializer.monad.map2/map2Eval consistency (30 milliseconds)

1628[info] - HeaderDeserializer.monad.map2/product-map consistency (30 milliseconds)

1629[info] - HeaderDeserializer.monad.mapOrKeepToMapEquivalence (28 milliseconds)

1630[info] - HeaderDeserializer.monad.monad left identity (22 milliseconds)

1631[info] - HeaderDeserializer.monad.monad right identity (26 milliseconds)

1632[info] - HeaderDeserializer.monad.monoidal left identity (21 milliseconds)

1633[info] - HeaderDeserializer.monad.monoidal right identity (25 milliseconds)

1634[info] - HeaderDeserializer.monad.mproduct consistent flatMap (55 milliseconds)

1635[info] - HeaderDeserializer.monad.productL consistent map2 (19 milliseconds)

1636[info] - HeaderDeserializer.monad.productR consistent map2 (16 milliseconds)

1637[info] - HeaderDeserializer.monad.replicateA_ consistent with replicateA.void (40 milliseconds)

1638[info] - HeaderDeserializer.monad.semigroupal associativity (30 milliseconds)

1639[info] - HeaderDeserializer.monad.tailRecM consistent flatMap (24 milliseconds)

1640[info] - HeaderDeserializer.monad.tailRecM stack safety (45 milliseconds)

1641[info] - HeaderDeserializer#delay (2 milliseconds)

1642[info] - HeaderDeserializer#option (1 millisecond)

1643[info] - HeaderDeserializer#unit (1 millisecond)

1644[info] - HeaderDeserializer#toString (1 millisecond)

1645[info] CommittableConsumerRecordLawsSpec:

1646[info] - CommittableConsumerRecord.eqLaws.eq.antisymmetry eq (5 milliseconds)

1647[info] - CommittableConsumerRecord.eqLaws.eq.reflexivity eq (4 milliseconds)

1648[info] - CommittableConsumerRecord.eqLaws.eq.symmetry eq (4 milliseconds)

1649[info] - CommittableConsumerRecord.eqLaws.eq.transitivity eq (6 milliseconds)

1650[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirst reference (5 milliseconds)

1651[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirstSome reference (4 milliseconds)

1652[info] - CommittableConsumerRecord.traverseLaws.traverse.contains all elements from itself (4 milliseconds)

1653[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with exists (2 milliseconds)

1654[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with forall (3 milliseconds)

1655[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant composition (3 milliseconds)

1656[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant identity (2 milliseconds)

1657[info] - CommittableConsumerRecord.traverseLaws.traverse.dropWhile_ reference (2 milliseconds)

1658[info] - CommittableConsumerRecord.traverseLaws.traverse.exists consistent with find (3 milliseconds)

1659[info] - CommittableConsumerRecord.traverseLaws.traverse.exists is lazy (3 milliseconds)

1660[info] - CommittableConsumerRecord.traverseLaws.traverse.filter_ reference (2 milliseconds)

1661[info] - CommittableConsumerRecord.traverseLaws.traverse.fold reference (1 millisecond)

1662[info] - CommittableConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (4 milliseconds)

1663[info] - CommittableConsumerRecord.traverseLaws.traverse.foldM identity (3 milliseconds)

1664[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (4 milliseconds)

1665[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight is lazy (3 milliseconds)

1666[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (3 milliseconds)

1667[info] - CommittableConsumerRecord.traverseLaws.traverse.forall consistent with exists (2 milliseconds)

1668[info] - CommittableConsumerRecord.traverseLaws.traverse.forall is lazy (2 milliseconds)

1669[info] - CommittableConsumerRecord.traverseLaws.traverse.forall true if empty (3 milliseconds)

1670[info] - CommittableConsumerRecord.traverseLaws.traverse.get reference (3 milliseconds)

1671[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant composition (4 milliseconds)

1672[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant identity (2 milliseconds)

1673[info] - CommittableConsumerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (3 milliseconds)

1674[info] - CommittableConsumerRecord.traverseLaws.traverse.nonEmpty reference (2 milliseconds)

1675[info] - CommittableConsumerRecord.traverseLaws.traverse.ordered consistency (4 milliseconds)

1676[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (2 milliseconds)

1677[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (3 milliseconds)

1678[info] - CommittableConsumerRecord.traverseLaws.traverse.takeWhile_ reference (4 milliseconds)

1679[info] - CommittableConsumerRecord.traverseLaws.traverse.toList reference (2 milliseconds)

1680[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse derive foldMap (2 milliseconds)

1681[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

1682[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse order consistency (3 milliseconds)

1683[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse parallel composition (3 milliseconds)

1684[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (4 milliseconds)

1685[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (2 milliseconds)

1686[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (4 milliseconds)

1687[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (2 milliseconds)

1688[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (2 milliseconds)

1689[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref updated (3 milliseconds)

1690[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (4 milliseconds)

1691[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (4 milliseconds)

1692[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse sequential composition (3 milliseconds)

1693[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse traverseTap (3 milliseconds)

1694[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (3 milliseconds)

1695[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (3 milliseconds)

1696[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (4 milliseconds)

1697[info] - CommittableConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (3 milliseconds)

1698[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (3 milliseconds)

1699[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (3 milliseconds)

1700[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (3 milliseconds)

1701[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (3 milliseconds)

1702[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (3 milliseconds)

1703[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (3 milliseconds)

1704[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (2 milliseconds)

1705[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (2 milliseconds)

1706[info] DeserializationExceptionSpec:

1707[info] DeserializationException

1708[info] - should have expected message and toString (1 millisecond)

1709[info] HeaderSpec:

1710[info] Header

1711[info] - toString should be Header(key -> value) (0 milliseconds)

1712[info] - should have consistent toString and Show (1 millisecond)

1713[info] - should return the key with key (0 milliseconds)

1714[info] - should return the value with value (0 milliseconds)

1715[info] - should deserialize with as (4 milliseconds)

1716[info] - should deserialize with attemptAs (0 milliseconds)

1717[info] HeaderLawsSpec:

1718[info] - Header.eqLaws.eq.antisymmetry eq (2 milliseconds)

1719[info] - Header.eqLaws.eq.reflexivity eq (1 millisecond)

1720[info] - Header.eqLaws.eq.symmetry eq (1 millisecond)

1721[info] - Header.eqLaws.eq.transitivity eq (1 millisecond)

1722[info] SerializerSpec:

1723[info] - Serializer[IO, *].contravariant.contravariant composition (247 milliseconds)

1724[info] - Serializer[IO, *].contravariant.contravariant identity (132 milliseconds)

1725[info] - Serializer[IO, *].contravariant.invariant composition (256 milliseconds)

1726[info] - Serializer[IO, *].contravariant.invariant identity (111 milliseconds)

1727[info] - Serializer#mapBytes (6 milliseconds)

1728[info] - Serializer#apply (8 milliseconds)

1729[info] - Serializer#identity (16 milliseconds)

1730[info] - Serializer#const (7 milliseconds)

1731[info] - Serializer#defer (10 milliseconds)

1732[info] - Serializer#fail (8 milliseconds)

1733[info] - Serializer#failWith (9 milliseconds)

1734[info] - Serializer#suspend (9 milliseconds)

1735[info] - Serializer#headers (22 milliseconds)

1736[info] - Serializer#topic (13 milliseconds)

1737[info] - Serializer#topic.unknown (9 milliseconds)

1738[info] - Serializer#asNull (5 milliseconds)

1739[info] - Serializer#empty (2 milliseconds)

1740[info] - Serializer#option (6 milliseconds)

1741[info] - Serializer#unit (0 milliseconds)

1742[info] - Serializer#toString (1 millisecond)

1743[info] - Serializer#string (5 milliseconds)

1744[info] - Serializer#uuid (12 milliseconds)

1745[info] - Serializer#uuid.default (16 milliseconds)

1746[info] - Serializer#double (12 milliseconds)

1747[info] - Serializer#float (18 milliseconds)

1748[info] - Serializer#int (4 milliseconds)

1749[info] - Serializer#long (6 milliseconds)

1750[info] - Serializer#short (13 milliseconds)

1751[info] DeserializerSpec:

1752[info] - Deserializer[IO, *].monadError.ap consistent with product + map (131 milliseconds)

1753[info] - Deserializer[IO, *].monadError.applicative homomorphism (136 milliseconds)

1754[info] - Deserializer[IO, *].monadError.applicative identity (109 milliseconds)

1755[info] - Deserializer[IO, *].monadError.applicative interchange (135 milliseconds)

1756[info] - Deserializer[IO, *].monadError.applicative map (77 milliseconds)

1757[info] - Deserializer[IO, *].monadError.applicative unit (71 milliseconds)

1758[info] - Deserializer[IO, *].monadError.applicativeError adaptError pure (77 milliseconds)

1759[info] - Deserializer[IO, *].monadError.applicativeError adaptError raise (117 milliseconds)

1760[info] - Deserializer[IO, *].monadError.applicativeError attempt consistent with attemptT (96 milliseconds)

1761[info] - Deserializer[IO, *].monadError.applicativeError attempt fromEither consistent with pure (109 milliseconds)

1762[info] - Deserializer[IO, *].monadError.applicativeError handle (180 milliseconds)

1763[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError left-distributes over ap (141 milliseconds)

1764[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError right-distributes over ap (110 milliseconds)

1765[info] - Deserializer[IO, *].monadError.applicativeError handleError consistent with recover (78 milliseconds)

1766[info] - Deserializer[IO, *].monadError.applicativeError handleError pure (69 milliseconds)

1767[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith consistent with recoverWith (63 milliseconds)

1768[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith pure (62 milliseconds)

1769[info] - Deserializer[IO, *].monadError.applicativeError handleWith (66 milliseconds)

1770[info] - Deserializer[IO, *].monadError.applicativeError onError pure (66 milliseconds)

1771[info] - Deserializer[IO, *].monadError.applicativeError onError raise (77 milliseconds)

1772[info] - Deserializer[IO, *].monadError.applicativeError pure attempt (70 milliseconds)

1773[info] - Deserializer[IO, *].monadError.applicativeError raiseError attempt (73 milliseconds)

1774[info] - Deserializer[IO, *].monadError.applicativeError recover consistent with recoverWith (76 milliseconds)

1775[info] - Deserializer[IO, *].monadError.applicativeError redeem is derived from attempt and map (95 milliseconds)

1776[info] - Deserializer[IO, *].monadError.applicativeError voidError consistent with void+handleError (78 milliseconds)

1777[info] - Deserializer[IO, *].monadError.apply composition (66 milliseconds)

1778[info] - Deserializer[IO, *].monadError.covariant composition (67 milliseconds)

1779[info] - Deserializer[IO, *].monadError.covariant identity (68 milliseconds)

1780[info] - Deserializer[IO, *].monadError.flatMap associativity (75 milliseconds)

1781[info] - Deserializer[IO, *].monadError.flatMap consistent apply (65 milliseconds)

1782[info] - Deserializer[IO, *].monadError.flatMap from tailRecM consistency (82 milliseconds)

1783[info] - Deserializer[IO, *].monadError.invariant composition (67 milliseconds)

1784[info] - Deserializer[IO, *].monadError.invariant identity (54 milliseconds)

1785[info] - Deserializer[IO, *].monadError.map flatMap coherence (63 milliseconds)

1786[info] - Deserializer[IO, *].monadError.map2/map2Eval consistency (70 milliseconds)

1787[info] - Deserializer[IO, *].monadError.map2/product-map consistency (67 milliseconds)

1788[info] - Deserializer[IO, *].monadError.mapOrKeepToMapEquivalence (69 milliseconds)

1789[info] - Deserializer[IO, *].monadError.monad left identity (62 milliseconds)

1790[info] - Deserializer[IO, *].monadError.monad right identity (66 milliseconds)

1791[info] - Deserializer[IO, *].monadError.monadError ensure consistency (68 milliseconds)

1792[info] - Deserializer[IO, *].monadError.monadError ensureOr consistency (66 milliseconds)

1793[info] - Deserializer[IO, *].monadError.monadError left zero (67 milliseconds)

1794[info] - Deserializer[IO, *].monadError.monadError redeemWith is derived from attempt and flatMap (68 milliseconds)

1795[info] - Deserializer[IO, *].monadError.monadError rethrow attempt (82 milliseconds)

1796[info] - Deserializer[IO, *].monadError.monoidal left identity (69 milliseconds)

1797[info] - Deserializer[IO, *].monadError.monoidal right identity (61 milliseconds)

1798[info] - Deserializer[IO, *].monadError.mproduct consistent flatMap (141 milliseconds)

1799[info] - Deserializer[IO, *].monadError.productL consistent map2 (73 milliseconds)

1800[info] - Deserializer[IO, *].monadError.productR consistent map2 (67 milliseconds)

1801[info] - Deserializer[IO, *].monadError.replicateA_ consistent with replicateA.void (73 milliseconds)

1802[info] - Deserializer[IO, *].monadError.semigroupal associativity (75 milliseconds)

1803[info] - Deserializer[IO, *].monadError.tailRecM consistent flatMap (92 milliseconds)

1804[info] - Deserializer[IO, *].monadError.tailRecM stack safety (280 milliseconds)

1805[info] - Deserializer#attempt (8 milliseconds)

1806[info] - Deserializer#fail (3 milliseconds)

1807[info] - Deserializer#failWith (3 milliseconds)

1808[info] - Deserializer#headers (9 milliseconds)

1809[info] - Deserializer#apply (6 milliseconds)

1810[info] - Deserializer#identity (2 milliseconds)

1811[info] - Deserializer#suspend (4 milliseconds)

1812[info] - Deserializer#topic (7 milliseconds)

1813[info] - Deserializer#topic.unknown (5 milliseconds)

1814[info] - Deserializer#attempt (implicit) (3 milliseconds)

1815[info] - Deserializer#option (3 milliseconds)

1816[info] - Deserializer#unit (1 millisecond)

1817[info] - Deserializer#toString (0 milliseconds)

1818[info] KafkaCredentialStoreSpec:

1819[info] KafkaCredentialStore

1820[info] fromPemStrings

1821[info] - should create a KafkaCredentialStore with the expected properties (1 millisecond)

1822[info] HeadersSpec:

1823[info] Headers#empty

1824[info] - should have toString as Headers() (0 milliseconds)

1825[info] - should return true for isEmpty (0 milliseconds)

1826[info] - should return false for nonEmpty (1 millisecond)

1827[info] - should return false for exists (0 milliseconds)

1828[info] - should not find any key (1 millisecond)

1829[info] - should concat empty (0 milliseconds)

1830[info] - should concat non-empty (0 milliseconds)

1831[info] - should return empty Chain from toChain (0 milliseconds)

1832[info] - should create a new Headers from append(Header) (0 milliseconds)

1833[info] - should create a new Headers from append(key, value) (1 millisecond)

1834[info] Headers#empty.asJava

1835[info] - add(header) throws IllegalStateException (2 milliseconds)

1836[info] - add(key, value) throws IllegalStateException (1 millisecond)

1837[info] - remove throws IllegalStateException (0 milliseconds)

1838[info] - lastHeader returns null (0 milliseconds)

1839[info] - headers returns empty iterable (1 millisecond)

1840[info] - toArray returns empty array (1 millisecond)

1841[info] - iterator.next throws NoSuchElementException (0 milliseconds)

1842[info] - iterator.hasNext returns false (0 milliseconds)

1843[info] Headers#nonEmpty.asJava

1844[info] - add(header) throws IllegalStateException (0 milliseconds)

1845[info] - add(key, value) throws IllegalStateException (1 millisecond)

1846[info] - remove throws IllegalStateException (1 millisecond)

1847[info] - lastHeader returns last header (1 millisecond)

1848[info] - lastHeaders returns existing header (1 millisecond)

1849[info] - lastHeader returns null for missing key (0 milliseconds)

1850[info] - headers returns matching headers (5 milliseconds)

1851[info] - headers returns empty if no matching headers (0 milliseconds)

1852[info] - toArray returns elements (0 milliseconds)

1853[info] - iterator returns elements (0 milliseconds)

1854[info] Headers#nonEmpty

1855[info] - should not be empty (0 milliseconds)

1856[info] - should be non empty (0 milliseconds)

1857[info] - should find an existing key (0 milliseconds)

1858[info] - should find the first key (1 millisecond)

1859[info] - should return true for existing key (1 millisecond)

1860[info] - should return false for non-existing key (1 millisecond)

1861[info] - should concat empty (0 milliseconds)

1862[info] - should concat non-empty (0 milliseconds)

1863[info] - should include the headers in toString (0 milliseconds)

1864[info] - should append one more header with append(Header) (0 milliseconds)

1865[info] - should append one more header with append(key, value) (1 millisecond)

1866[info] Headers#apply

1867[info] - returns empty for no headers (0 milliseconds)

1868[info] - returns non-empty for at least one header (1 millisecond)

1869[info] Headers#fromChain

1870[info] - returns empty for empty chain (0 milliseconds)

1871[info] - returns non-empty for non-empty chain (1 millisecond)

1872[info] Headers#fromSeq

1873[info] - returns empty for empty seq (0 milliseconds)

1874[info] - returns non-empty for non-empty seq (1 millisecond)

1875[info] Headers#fromIterable

1876[info] - returns empty for empty iterable (0 milliseconds)

1877[info] - returns non-empty for non-empty iterable (0 milliseconds)

1878[info] SyntaxSpec:

1879[info] Map#filterKeysStrictValuesList

1880[info] - should be the same as toList.collect (3 milliseconds)

1881[info] KafkaHeaders#asScala

1882[info] - should convert empty (0 milliseconds)

1883[info] - should convert non-empty (1 millisecond)

1884[info] KafkaFuture.cancelable

1885Build timeouts: 1, would retry

1886Retrying build, retry 1/2, force Scala version:false, enable migration:

1887[sbt_options] declare -a sbt_options=()

1888[process_args] java_version = '21'

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

1890# Executing command line:

1891java

1892-Dfile.encoding=UTF-8

1893-Dcommunitybuild.scala=3.8.1-RC1

1894-Dcommunitybuild.project.dependencies.add=

1895-Xmx7G

1896-Xms4G

1897-Xss8M

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

1899-Dscala.ext.dirs=/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_21

1900-jar

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

1902"setCrossScalaVersions 3.8.1-RC1"

1903"++3.8.1-RC1 -v"

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

1905"set every credentials := Nil"

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

1907"removeScalacOptionsStartingWith -P:wartremover"

1908"set core/Test/unmanagedSources/excludeFilter ~= {_ || "KafkaProducerConnectionSpec.scala" || "KafkaConsumerSpec.scala" || "KafkaProducerSpec.scala" || "TransactionalKafkaProducerSpec.scala" || "TransactionalKafkaProducerTimeoutSpec.scala" || "KafkaAdminClientSpec.scala"} "

1909moduleMappings

1910"runBuild 3.8.1-RC1 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}""" com.github.fd4s%fs2-kafka com.github.fd4s%fs2-kafka-vulcan com.github.fd4s%fs2-kafka-vulcan-testkit-munit"

1911

1912[info] welcome to sbt 1.11.7 (Eclipse Adoptium Java 21)

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

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

1915[info] loading settings for project fs2-kafka from build.sbt...

1916[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1917[info] set current project to fs2-kafka (in build file:/build/repo/)

1918Execute setCrossScalaVersions: 3.8.1-RC1

1919[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1920OpenCB::Changing crossVersion 3.8.1-RC1 -> 3.8.1-RC1 in vulcan/crossScalaVersions

1921OpenCB::Changing crossVersion 3.8.1-RC1 -> 3.8.1-RC1 in vulcan-testkit-munit/crossScalaVersions

1922OpenCB::Changing crossVersion 3.8.1-RC1 -> 3.8.1-RC1 in fs2-kafka/crossScalaVersions

1923OpenCB::Changing crossVersion 3.8.1-RC1 -> 3.8.1-RC1 in core/crossScalaVersions

1924[info] set current project to fs2-kafka (in build file:/build/repo/)

1925[info] Setting Scala version to 3.8.1-RC1 on 4 projects.

1926[info] Switching Scala version on:

1927[info] * fs2-kafka (2.12.20, 2.13.17, 3.8.1-RC1)

1928[info] vulcan-testkit-munit (2.12.20, 2.13.17, 3.8.1-RC1)

1929[info] core (2.12.20, 2.13.17, 3.8.1-RC1)

1930[info] vulcan (2.12.20, 2.13.17, 3.8.1-RC1)

1931[info] Excluding projects:

1932[info] docs (2.13.17)

1933[info] Reapplying settings...

1934[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1935[info] set current project to fs2-kafka (in build file:/build/repo/)

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

1937[info] Reapplying settings...

1938[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1939[info] set current project to fs2-kafka (in build file:/build/repo/)

1940[info] Defining Global / credentials, core / credentials and 3 others.

1941[info] The new values will be used by Compile / scalafmtOnly, IntegrationTest / scalafmtOnly and 42 others.

1942[info] Run `last` for details.

1943[info] Reapplying settings...

1944[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1945[info] set current project to fs2-kafka (in build file:/build/repo/)

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

1947[info] Reapplying settings...

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

1949

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

1951 Did you mean allExcludeDependencies ?

1952 , retry without global scopes

1953[info] Reapplying settings...

1954[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1955[info] set current project to fs2-kafka (in build file:/build/repo/)

1956Execute removeScalacOptionsStartingWith: -P:wartremover

1957[info] Reapplying settings...

1958[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1959[info] set current project to fs2-kafka (in build file:/build/repo/)

1960[info] Defining core / Test / unmanagedSources / excludeFilter

1961[info] The new value will be used by core / Test / unmanagedSources / fileInputs

1962[info] Reapplying settings...

1963[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1964[info] set current project to fs2-kafka (in build file:/build/repo/)

1965[success] Total time: 0 s, completed Jan 13, 2026, 10:08:24 PM

1966Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}

1967Parsed config: Success(ProjectBuildConfig(ProjectsConfig(List(),Map()),Full,List()))

1968Starting build...

1969Projects: Set(fs2-kafka, vulcan, vulcan-testkit-munit, core)

1970Starting build for ProjectRef(file:/build/repo/,fs2-kafka) (fs2-kafka)... [0/4]

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

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

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

1974Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

1975Starting build for ProjectRef(file:/build/repo/,vulcan) (fs2-kafka-vulcan)... [1/4]

1976Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

1977[info] PackageSpec:

1978[info] avroSerializer

1979[info] - should be available given explicit settings (345 milliseconds)

1980[info] avroDeserializer

1981[info] - should be available given explicit settings (3 milliseconds)

1982[info] avroSerializer/avroDeserializer

198322:08:30.543 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

1984 auto.register.schemas = true

1985 avro.reflection.allow.null = false

1986 avro.use.logical.type.converters = false

1987 basic.auth.credentials.source = URL

1988 basic.auth.user.info = [hidden]

1989 bearer.auth.cache.expiry.buffer.seconds = 300

1990 bearer.auth.client.id = null

1991 bearer.auth.client.secret = null

1992 bearer.auth.credentials.source = STATIC_TOKEN

1993 bearer.auth.custom.provider.class = null

1994 bearer.auth.identity.pool.id = null

1995 bearer.auth.issuer.endpoint.url = null

1996 bearer.auth.logical.cluster = null

1997 bearer.auth.scope = null

1998 bearer.auth.scope.claim.name = scope

1999 bearer.auth.sub.claim.name = sub

2000 bearer.auth.token = [hidden]

2001 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2002 http.connect.timeout.ms = 60000

2003 http.read.timeout.ms = 60000

2004 id.compatibility.strict = true

2005 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2006 latest.cache.size = 1000

2007 latest.cache.ttl.sec = -1

2008 latest.compatibility.strict = true

2009 max.retries = 3

2010 max.schemas.per.subject = 1000

2011 normalize.schemas = false

2012 propagate.schema.tags = false

2013 proxy.host =

2014 proxy.port = -1

2015 retries.max.wait.ms = 20000

2016 retries.wait.ms = 1000

2017 rule.actions = []

2018 rule.executors = []

2019 rule.service.loader.enable = true

2020 schema.format = null

2021 schema.reflection = false

2022 schema.registry.basic.auth.user.info = [hidden]

2023 schema.registry.ssl.cipher.suites = null

2024 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2025 schema.registry.ssl.endpoint.identification.algorithm = https

2026 schema.registry.ssl.engine.factory.class = null

2027 schema.registry.ssl.key.password = null

2028 schema.registry.ssl.keymanager.algorithm = SunX509

2029 schema.registry.ssl.keystore.certificate.chain = null

2030 schema.registry.ssl.keystore.key = null

2031 schema.registry.ssl.keystore.location = null

2032 schema.registry.ssl.keystore.password = null

2033 schema.registry.ssl.keystore.type = JKS

2034 schema.registry.ssl.protocol = TLSv1.3

2035 schema.registry.ssl.provider = null

2036 schema.registry.ssl.secure.random.implementation = null

2037 schema.registry.ssl.trustmanager.algorithm = PKIX

2038 schema.registry.ssl.truststore.certificates = null

2039 schema.registry.ssl.truststore.location = null

2040 schema.registry.ssl.truststore.password = null

2041 schema.registry.ssl.truststore.type = JKS

2042 schema.registry.url = []

2043 schema.registry.url.randomize = false

2044 specific.avro.key.type = null

2045 specific.avro.reader = false

2046 specific.avro.value.type = null

2047 use.latest.version = false

2048 use.latest.with.metadata = null

2049 use.schema.id = -1

2050 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2051

205222:08:30.543 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2053 auto.register.schemas = true

2054 avro.reflection.allow.null = false

2055 avro.remove.java.properties = false

2056 avro.use.logical.type.converters = false

2057 basic.auth.credentials.source = URL

2058 basic.auth.user.info = [hidden]

2059 bearer.auth.cache.expiry.buffer.seconds = 300

2060 bearer.auth.client.id = null

2061 bearer.auth.client.secret = null

2062 bearer.auth.credentials.source = STATIC_TOKEN

2063 bearer.auth.custom.provider.class = null

2064 bearer.auth.identity.pool.id = null

2065 bearer.auth.issuer.endpoint.url = null

2066 bearer.auth.logical.cluster = null

2067 bearer.auth.scope = null

2068 bearer.auth.scope.claim.name = scope

2069 bearer.auth.sub.claim.name = sub

2070 bearer.auth.token = [hidden]

2071 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2072 http.connect.timeout.ms = 60000

2073 http.read.timeout.ms = 60000

2074 id.compatibility.strict = true

2075 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2076 latest.cache.size = 1000

2077 latest.cache.ttl.sec = -1

2078 latest.compatibility.strict = true

2079 max.retries = 3

2080 max.schemas.per.subject = 1000

2081 normalize.schemas = false

2082 propagate.schema.tags = false

2083 proxy.host =

2084 proxy.port = -1

2085 retries.max.wait.ms = 20000

2086 retries.wait.ms = 1000

2087 rule.actions = []

2088 rule.executors = []

2089 rule.service.loader.enable = true

2090 schema.format = null

2091 schema.reflection = false

2092 schema.registry.basic.auth.user.info = [hidden]

2093 schema.registry.ssl.cipher.suites = null

2094 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2095 schema.registry.ssl.endpoint.identification.algorithm = https

2096 schema.registry.ssl.engine.factory.class = null

2097 schema.registry.ssl.key.password = null

2098 schema.registry.ssl.keymanager.algorithm = SunX509

2099 schema.registry.ssl.keystore.certificate.chain = null

2100 schema.registry.ssl.keystore.key = null

2101 schema.registry.ssl.keystore.location = null

2102 schema.registry.ssl.keystore.password = null

2103 schema.registry.ssl.keystore.type = JKS

2104 schema.registry.ssl.protocol = TLSv1.3

2105 schema.registry.ssl.provider = null

2106 schema.registry.ssl.secure.random.implementation = null

2107 schema.registry.ssl.trustmanager.algorithm = PKIX

2108 schema.registry.ssl.truststore.certificates = null

2109 schema.registry.ssl.truststore.location = null

2110 schema.registry.ssl.truststore.password = null

2111 schema.registry.ssl.truststore.type = JKS

2112 schema.registry.url = []

2113 schema.registry.url.randomize = false

2114 use.latest.version = false

2115 use.latest.with.metadata = null

2116 use.schema.id = -1

2117 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2118

2119[info] - should be able to do roundtrip serialization (362 milliseconds)

212022:08:30.657 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2121 auto.register.schemas = true

2122 avro.reflection.allow.null = false

2123 avro.use.logical.type.converters = false

2124 basic.auth.credentials.source = URL

2125 basic.auth.user.info = [hidden]

2126 bearer.auth.cache.expiry.buffer.seconds = 300

2127 bearer.auth.client.id = null

2128 bearer.auth.client.secret = null

2129 bearer.auth.credentials.source = STATIC_TOKEN

2130 bearer.auth.custom.provider.class = null

2131 bearer.auth.identity.pool.id = null

2132 bearer.auth.issuer.endpoint.url = null

2133 bearer.auth.logical.cluster = null

2134 bearer.auth.scope = null

2135 bearer.auth.scope.claim.name = scope

2136 bearer.auth.sub.claim.name = sub

2137 bearer.auth.token = [hidden]

2138 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2139 http.connect.timeout.ms = 60000

2140 http.read.timeout.ms = 60000

2141 id.compatibility.strict = true

2142 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2143 latest.cache.size = 1000

2144 latest.cache.ttl.sec = -1

2145 latest.compatibility.strict = true

2146 max.retries = 3

2147 max.schemas.per.subject = 1000

2148 normalize.schemas = false

2149 propagate.schema.tags = false

2150 proxy.host =

2151 proxy.port = -1

2152 retries.max.wait.ms = 20000

2153 retries.wait.ms = 1000

2154 rule.actions = []

2155 rule.executors = []

2156 rule.service.loader.enable = true

2157 schema.format = null

2158 schema.reflection = false

2159 schema.registry.basic.auth.user.info = [hidden]

2160 schema.registry.ssl.cipher.suites = null

2161 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2162 schema.registry.ssl.endpoint.identification.algorithm = https

2163 schema.registry.ssl.engine.factory.class = null

2164 schema.registry.ssl.key.password = null

2165 schema.registry.ssl.keymanager.algorithm = SunX509

2166 schema.registry.ssl.keystore.certificate.chain = null

2167 schema.registry.ssl.keystore.key = null

2168 schema.registry.ssl.keystore.location = null

2169 schema.registry.ssl.keystore.password = null

2170 schema.registry.ssl.keystore.type = JKS

2171 schema.registry.ssl.protocol = TLSv1.3

2172 schema.registry.ssl.provider = null

2173 schema.registry.ssl.secure.random.implementation = null

2174 schema.registry.ssl.trustmanager.algorithm = PKIX

2175 schema.registry.ssl.truststore.certificates = null

2176 schema.registry.ssl.truststore.location = null

2177 schema.registry.ssl.truststore.password = null

2178 schema.registry.ssl.truststore.type = JKS

2179 schema.registry.url = []

2180 schema.registry.url.randomize = false

2181 specific.avro.key.type = null

2182 specific.avro.reader = false

2183 specific.avro.value.type = null

2184 use.latest.version = false

2185 use.latest.with.metadata = null

2186 use.schema.id = -1

2187 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2188

218922:08:30.657 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2190 auto.register.schemas = true

2191 avro.reflection.allow.null = false

2192 avro.remove.java.properties = false

2193 avro.use.logical.type.converters = false

2194 basic.auth.credentials.source = URL

2195 basic.auth.user.info = [hidden]

2196 bearer.auth.cache.expiry.buffer.seconds = 300

2197 bearer.auth.client.id = null

2198 bearer.auth.client.secret = null

2199 bearer.auth.credentials.source = STATIC_TOKEN

2200 bearer.auth.custom.provider.class = null

2201 bearer.auth.identity.pool.id = null

2202 bearer.auth.issuer.endpoint.url = null

2203 bearer.auth.logical.cluster = null

2204 bearer.auth.scope = null

2205 bearer.auth.scope.claim.name = scope

2206 bearer.auth.sub.claim.name = sub

2207 bearer.auth.token = [hidden]

2208 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2209 http.connect.timeout.ms = 60000

2210 http.read.timeout.ms = 60000

2211 id.compatibility.strict = true

2212 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2213 latest.cache.size = 1000

2214 latest.cache.ttl.sec = -1

2215 latest.compatibility.strict = true

2216 max.retries = 3

2217 max.schemas.per.subject = 1000

2218 normalize.schemas = false

2219 propagate.schema.tags = false

2220 proxy.host =

2221 proxy.port = -1

2222 retries.max.wait.ms = 20000

2223 retries.wait.ms = 1000

2224 rule.actions = []

2225 rule.executors = []

2226 rule.service.loader.enable = true

2227 schema.format = null

2228 schema.reflection = false

2229 schema.registry.basic.auth.user.info = [hidden]

2230 schema.registry.ssl.cipher.suites = null

2231 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2232 schema.registry.ssl.endpoint.identification.algorithm = https

2233 schema.registry.ssl.engine.factory.class = null

2234 schema.registry.ssl.key.password = null

2235 schema.registry.ssl.keymanager.algorithm = SunX509

2236 schema.registry.ssl.keystore.certificate.chain = null

2237 schema.registry.ssl.keystore.key = null

2238 schema.registry.ssl.keystore.location = null

2239 schema.registry.ssl.keystore.password = null

2240 schema.registry.ssl.keystore.type = JKS

2241 schema.registry.ssl.protocol = TLSv1.3

2242 schema.registry.ssl.provider = null

2243 schema.registry.ssl.secure.random.implementation = null

2244 schema.registry.ssl.trustmanager.algorithm = PKIX

2245 schema.registry.ssl.truststore.certificates = null

2246 schema.registry.ssl.truststore.location = null

2247 schema.registry.ssl.truststore.password = null

2248 schema.registry.ssl.truststore.type = JKS

2249 schema.registry.url = []

2250 schema.registry.url.randomize = false

2251 use.latest.version = false

2252 use.latest.with.metadata = null

2253 use.schema.id = -1

2254 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2255

2256[info] - should be able to do roundtrip serialization using compatible schemas (17 milliseconds)

225722:08:30.676 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2258 auto.register.schemas = true

2259 avro.reflection.allow.null = false

2260 avro.remove.java.properties = false

2261 avro.use.logical.type.converters = false

2262 basic.auth.credentials.source = URL

2263 basic.auth.user.info = [hidden]

2264 bearer.auth.cache.expiry.buffer.seconds = 300

2265 bearer.auth.client.id = null

2266 bearer.auth.client.secret = null

2267 bearer.auth.credentials.source = STATIC_TOKEN

2268 bearer.auth.custom.provider.class = null

2269 bearer.auth.identity.pool.id = null

2270 bearer.auth.issuer.endpoint.url = null

2271 bearer.auth.logical.cluster = null

2272 bearer.auth.scope = null

2273 bearer.auth.scope.claim.name = scope

2274 bearer.auth.sub.claim.name = sub

2275 bearer.auth.token = [hidden]

2276 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2277 http.connect.timeout.ms = 60000

2278 http.read.timeout.ms = 60000

2279 id.compatibility.strict = true

2280 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2281 latest.cache.size = 1000

2282 latest.cache.ttl.sec = -1

2283 latest.compatibility.strict = true

2284 max.retries = 3

2285 max.schemas.per.subject = 1000

2286 normalize.schemas = false

2287 propagate.schema.tags = false

2288 proxy.host =

2289 proxy.port = -1

2290 retries.max.wait.ms = 20000

2291 retries.wait.ms = 1000

2292 rule.actions = []

2293 rule.executors = []

2294 rule.service.loader.enable = true

2295 schema.format = null

2296 schema.reflection = false

2297 schema.registry.basic.auth.user.info = [hidden]

2298 schema.registry.ssl.cipher.suites = null

2299 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2300 schema.registry.ssl.endpoint.identification.algorithm = https

2301 schema.registry.ssl.engine.factory.class = null

2302 schema.registry.ssl.key.password = null

2303 schema.registry.ssl.keymanager.algorithm = SunX509

2304 schema.registry.ssl.keystore.certificate.chain = null

2305 schema.registry.ssl.keystore.key = null

2306 schema.registry.ssl.keystore.location = null

2307 schema.registry.ssl.keystore.password = null

2308 schema.registry.ssl.keystore.type = JKS

2309 schema.registry.ssl.protocol = TLSv1.3

2310 schema.registry.ssl.provider = null

2311 schema.registry.ssl.secure.random.implementation = null

2312 schema.registry.ssl.trustmanager.algorithm = PKIX

2313 schema.registry.ssl.truststore.certificates = null

2314 schema.registry.ssl.truststore.location = null

2315 schema.registry.ssl.truststore.password = null

2316 schema.registry.ssl.truststore.type = JKS

2317 schema.registry.url = []

2318 schema.registry.url.randomize = false

2319 use.latest.version = false

2320 use.latest.with.metadata = null

2321 use.schema.id = -1

2322 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2323

232422:08:30.676 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2325 auto.register.schemas = true

2326 avro.reflection.allow.null = false

2327 avro.use.logical.type.converters = false

2328 basic.auth.credentials.source = URL

2329 basic.auth.user.info = [hidden]

2330 bearer.auth.cache.expiry.buffer.seconds = 300

2331 bearer.auth.client.id = null

2332 bearer.auth.client.secret = null

2333 bearer.auth.credentials.source = STATIC_TOKEN

2334 bearer.auth.custom.provider.class = null

2335 bearer.auth.identity.pool.id = null

2336 bearer.auth.issuer.endpoint.url = null

2337 bearer.auth.logical.cluster = null

2338 bearer.auth.scope = null

2339 bearer.auth.scope.claim.name = scope

2340 bearer.auth.sub.claim.name = sub

2341 bearer.auth.token = [hidden]

2342 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2343 http.connect.timeout.ms = 60000

2344 http.read.timeout.ms = 60000

2345 id.compatibility.strict = true

2346 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2347 latest.cache.size = 1000

2348 latest.cache.ttl.sec = -1

2349 latest.compatibility.strict = true

2350 max.retries = 3

2351 max.schemas.per.subject = 1000

2352 normalize.schemas = false

2353 propagate.schema.tags = false

2354 proxy.host =

2355 proxy.port = -1

2356 retries.max.wait.ms = 20000

2357 retries.wait.ms = 1000

2358 rule.actions = []

2359 rule.executors = []

2360 rule.service.loader.enable = true

2361 schema.format = null

2362 schema.reflection = false

2363 schema.registry.basic.auth.user.info = [hidden]

2364 schema.registry.ssl.cipher.suites = null

2365 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2366 schema.registry.ssl.endpoint.identification.algorithm = https

2367 schema.registry.ssl.engine.factory.class = null

2368 schema.registry.ssl.key.password = null

2369 schema.registry.ssl.keymanager.algorithm = SunX509

2370 schema.registry.ssl.keystore.certificate.chain = null

2371 schema.registry.ssl.keystore.key = null

2372 schema.registry.ssl.keystore.location = null

2373 schema.registry.ssl.keystore.password = null

2374 schema.registry.ssl.keystore.type = JKS

2375 schema.registry.ssl.protocol = TLSv1.3

2376 schema.registry.ssl.provider = null

2377 schema.registry.ssl.secure.random.implementation = null

2378 schema.registry.ssl.trustmanager.algorithm = PKIX

2379 schema.registry.ssl.truststore.certificates = null

2380 schema.registry.ssl.truststore.location = null

2381 schema.registry.ssl.truststore.password = null

2382 schema.registry.ssl.truststore.type = JKS

2383 schema.registry.url = []

2384 schema.registry.url.randomize = false

2385 specific.avro.key.type = null

2386 specific.avro.reader = false

2387 specific.avro.value.type = null

2388 use.latest.version = false

2389 use.latest.with.metadata = null

2390 use.schema.id = -1

2391 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2392

2393[info] - should error when reader and writer schemas have mismatching logical types (17 milliseconds)

2394[info] AvroSettingsSpec:

2395[info] AvroSettings

2396[info] - should provide withAutoRegisterSchemas (105 milliseconds)

2397[info] - should provide withKeySubjectNameStrategy (7 milliseconds)

2398[info] - should provide withValueSubjectNameStrategy (4 milliseconds)

2399[info] - should provide withProperty (5 milliseconds)

2400[info] - should provide withProperties (3 milliseconds)

2401[info] - should provide withProperties(Map) (4 milliseconds)

2402[info] - should provide withCreateAvroDeserializer (1 millisecond)

2403[info] - should provide withCreateAvroSerializer (1 millisecond)

2404[info] - should provide withRegisterSchema (0 milliseconds)

2405[info] - should provide toString (1 millisecond)

2406[info] AvroSerializerSpec:

2407[info] AvroSerializer

240822:08:30.872 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2409 auto.register.schemas = true

2410 avro.reflection.allow.null = false

2411 avro.remove.java.properties = false

2412 avro.use.logical.type.converters = false

2413 basic.auth.credentials.source = URL

2414 basic.auth.user.info = [hidden]

2415 bearer.auth.cache.expiry.buffer.seconds = 300

2416 bearer.auth.client.id = null

2417 bearer.auth.client.secret = null

2418 bearer.auth.credentials.source = STATIC_TOKEN

2419 bearer.auth.custom.provider.class = null

2420 bearer.auth.identity.pool.id = null

2421 bearer.auth.issuer.endpoint.url = null

2422 bearer.auth.logical.cluster = null

2423 bearer.auth.scope = null

2424 bearer.auth.scope.claim.name = scope

2425 bearer.auth.sub.claim.name = sub

2426 bearer.auth.token = [hidden]

2427 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2428 http.connect.timeout.ms = 60000

2429 http.read.timeout.ms = 60000

2430 id.compatibility.strict = true

2431 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2432 latest.cache.size = 1000

2433 latest.cache.ttl.sec = -1

2434 latest.compatibility.strict = true

2435 max.retries = 3

2436 max.schemas.per.subject = 1000

2437 normalize.schemas = false

2438 propagate.schema.tags = false

2439 proxy.host =

2440 proxy.port = -1

2441 retries.max.wait.ms = 20000

2442 retries.wait.ms = 1000

2443 rule.actions = []

2444 rule.executors = []

2445 rule.service.loader.enable = true

2446 schema.format = null

2447 schema.reflection = false

2448 schema.registry.basic.auth.user.info = [hidden]

2449 schema.registry.ssl.cipher.suites = null

2450 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2451 schema.registry.ssl.endpoint.identification.algorithm = https

2452 schema.registry.ssl.engine.factory.class = null

2453 schema.registry.ssl.key.password = null

2454 schema.registry.ssl.keymanager.algorithm = SunX509

2455 schema.registry.ssl.keystore.certificate.chain = null

2456 schema.registry.ssl.keystore.key = null

2457 schema.registry.ssl.keystore.location = null

2458 schema.registry.ssl.keystore.password = null

2459 schema.registry.ssl.keystore.type = JKS

2460 schema.registry.ssl.protocol = TLSv1.3

2461 schema.registry.ssl.provider = null

2462 schema.registry.ssl.secure.random.implementation = null

2463 schema.registry.ssl.trustmanager.algorithm = PKIX

2464 schema.registry.ssl.truststore.certificates = null

2465 schema.registry.ssl.truststore.location = null

2466 schema.registry.ssl.truststore.password = null

2467 schema.registry.ssl.truststore.type = JKS

2468 schema.registry.url = []

2469 schema.registry.url.randomize = false

2470 use.latest.version = false

2471 use.latest.with.metadata = null

2472 use.schema.id = -1

2473 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2474

247522:08:30.875 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2476 auto.register.schemas = true

2477 avro.reflection.allow.null = false

2478 avro.remove.java.properties = false

2479 avro.use.logical.type.converters = false

2480 basic.auth.credentials.source = URL

2481 basic.auth.user.info = [hidden]

2482 bearer.auth.cache.expiry.buffer.seconds = 300

2483 bearer.auth.client.id = null

2484 bearer.auth.client.secret = null

2485 bearer.auth.credentials.source = STATIC_TOKEN

2486 bearer.auth.custom.provider.class = null

2487 bearer.auth.identity.pool.id = null

2488 bearer.auth.issuer.endpoint.url = null

2489 bearer.auth.logical.cluster = null

2490 bearer.auth.scope = null

2491 bearer.auth.scope.claim.name = scope

2492 bearer.auth.sub.claim.name = sub

2493 bearer.auth.token = [hidden]

2494 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2495 http.connect.timeout.ms = 60000

2496 http.read.timeout.ms = 60000

2497 id.compatibility.strict = true

2498 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2499 latest.cache.size = 1000

2500 latest.cache.ttl.sec = -1

2501 latest.compatibility.strict = true

2502 max.retries = 3

2503 max.schemas.per.subject = 1000

2504 normalize.schemas = false

2505 propagate.schema.tags = false

2506 proxy.host =

2507 proxy.port = -1

2508 retries.max.wait.ms = 20000

2509 retries.wait.ms = 1000

2510 rule.actions = []

2511 rule.executors = []

2512 rule.service.loader.enable = true

2513 schema.format = null

2514 schema.reflection = false

2515 schema.registry.basic.auth.user.info = [hidden]

2516 schema.registry.ssl.cipher.suites = null

2517 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2518 schema.registry.ssl.endpoint.identification.algorithm = https

2519 schema.registry.ssl.engine.factory.class = null

2520 schema.registry.ssl.key.password = null

2521 schema.registry.ssl.keymanager.algorithm = SunX509

2522 schema.registry.ssl.keystore.certificate.chain = null

2523 schema.registry.ssl.keystore.key = null

2524 schema.registry.ssl.keystore.location = null

2525 schema.registry.ssl.keystore.password = null

2526 schema.registry.ssl.keystore.type = JKS

2527 schema.registry.ssl.protocol = TLSv1.3

2528 schema.registry.ssl.provider = null

2529 schema.registry.ssl.secure.random.implementation = null

2530 schema.registry.ssl.trustmanager.algorithm = PKIX

2531 schema.registry.ssl.truststore.certificates = null

2532 schema.registry.ssl.truststore.location = null

2533 schema.registry.ssl.truststore.password = null

2534 schema.registry.ssl.truststore.type = JKS

2535 schema.registry.url = []

2536 schema.registry.url.randomize = false

2537 use.latest.version = false

2538 use.latest.with.metadata = null

2539 use.schema.id = -1

2540 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2541

2542[info] - can create a serializer (7 milliseconds)

254322:08:30.879 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2544 auto.register.schemas = true

2545 avro.reflection.allow.null = false

2546 avro.remove.java.properties = false

2547 avro.use.logical.type.converters = false

2548 basic.auth.credentials.source = URL

2549 basic.auth.user.info = [hidden]

2550 bearer.auth.cache.expiry.buffer.seconds = 300

2551 bearer.auth.client.id = null

2552 bearer.auth.client.secret = null

2553 bearer.auth.credentials.source = STATIC_TOKEN

2554 bearer.auth.custom.provider.class = null

2555 bearer.auth.identity.pool.id = null

2556 bearer.auth.issuer.endpoint.url = null

2557 bearer.auth.logical.cluster = null

2558 bearer.auth.scope = null

2559 bearer.auth.scope.claim.name = scope

2560 bearer.auth.sub.claim.name = sub

2561 bearer.auth.token = [hidden]

2562 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2563 http.connect.timeout.ms = 60000

2564 http.read.timeout.ms = 60000

2565 id.compatibility.strict = true

2566 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2567 latest.cache.size = 1000

2568 latest.cache.ttl.sec = -1

2569 latest.compatibility.strict = true

2570 max.retries = 3

2571 max.schemas.per.subject = 1000

2572 normalize.schemas = false

2573 propagate.schema.tags = false

2574 proxy.host =

2575 proxy.port = -1

2576 retries.max.wait.ms = 20000

2577 retries.wait.ms = 1000

2578 rule.actions = []

2579 rule.executors = []

2580 rule.service.loader.enable = true

2581 schema.format = null

2582 schema.reflection = false

2583 schema.registry.basic.auth.user.info = [hidden]

2584 schema.registry.ssl.cipher.suites = null

2585 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2586 schema.registry.ssl.endpoint.identification.algorithm = https

2587 schema.registry.ssl.engine.factory.class = null

2588 schema.registry.ssl.key.password = null

2589 schema.registry.ssl.keymanager.algorithm = SunX509

2590 schema.registry.ssl.keystore.certificate.chain = null

2591 schema.registry.ssl.keystore.key = null

2592 schema.registry.ssl.keystore.location = null

2593 schema.registry.ssl.keystore.password = null

2594 schema.registry.ssl.keystore.type = JKS

2595 schema.registry.ssl.protocol = TLSv1.3

2596 schema.registry.ssl.provider = null

2597 schema.registry.ssl.secure.random.implementation = null

2598 schema.registry.ssl.trustmanager.algorithm = PKIX

2599 schema.registry.ssl.truststore.certificates = null

2600 schema.registry.ssl.truststore.location = null

2601 schema.registry.ssl.truststore.password = null

2602 schema.registry.ssl.truststore.type = JKS

2603 schema.registry.url = []

2604 schema.registry.url.randomize = false

2605 use.latest.version = false

2606 use.latest.with.metadata = null

2607 use.schema.id = -1

2608 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2609

2610[info] - auto-registers union schemas (9 milliseconds)

2611[info] - raises schema errors (8 milliseconds)

2612[info] - toString (1 millisecond)

2613[info] AuthSpec:

2614[info] Auth.Basic

2615[info] - should include the username in toString (3 milliseconds)

2616[info] - should not include the password in toString (5 milliseconds)

2617[info] Auth.Bearer

2618[info] - should not include the token in toString (3 milliseconds)

2619[info] Auth.None

2620[info] - should have None as toString (1 millisecond)

2621[info] SchemaRegistryClientSettingsSpec:

2622[info] SchemaRegistryClientSettings

2623[info] - should provide withMaxCacheSize (0 milliseconds)

2624[info] - should provide withAuth(Auth.Basic) (6 milliseconds)

2625[info] - should provide withAuth(Auth.Bearer) (2 milliseconds)

2626[info] - should provide withAuth(Auth.None) (0 milliseconds)

2627[info] - should provide withProperty (2 milliseconds)

2628[info] - should provide withProperties (2 milliseconds)

2629[info] - should provide withProperties(Map) (5 milliseconds)

2630[info] - should provide withCreateSchemaRegistryClient (3 milliseconds)

2631[info] - should provide toString (6 milliseconds)

2632[info] - should provide Show (1 millisecond)

2633[info] AvroDeserializerSpec:

2634[info] AvroDeserializer

263522:08:30.975 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2636 auto.register.schemas = true

2637 avro.reflection.allow.null = false

2638 avro.use.logical.type.converters = false

2639 basic.auth.credentials.source = URL

2640 basic.auth.user.info = [hidden]

2641 bearer.auth.cache.expiry.buffer.seconds = 300

2642 bearer.auth.client.id = null

2643 bearer.auth.client.secret = null

2644 bearer.auth.credentials.source = STATIC_TOKEN

2645 bearer.auth.custom.provider.class = null

2646 bearer.auth.identity.pool.id = null

2647 bearer.auth.issuer.endpoint.url = null

2648 bearer.auth.logical.cluster = null

2649 bearer.auth.scope = null

2650 bearer.auth.scope.claim.name = scope

2651 bearer.auth.sub.claim.name = sub

2652 bearer.auth.token = [hidden]

2653 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2654 http.connect.timeout.ms = 60000

2655 http.read.timeout.ms = 60000

2656 id.compatibility.strict = true

2657 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2658 latest.cache.size = 1000

2659 latest.cache.ttl.sec = -1

2660 latest.compatibility.strict = true

2661 max.retries = 3

2662 max.schemas.per.subject = 1000

2663 normalize.schemas = false

2664 propagate.schema.tags = false

2665 proxy.host =

2666 proxy.port = -1

2667 retries.max.wait.ms = 20000

2668 retries.wait.ms = 1000

2669 rule.actions = []

2670 rule.executors = []

2671 rule.service.loader.enable = true

2672 schema.format = null

2673 schema.reflection = false

2674 schema.registry.basic.auth.user.info = [hidden]

2675 schema.registry.ssl.cipher.suites = null

2676 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2677 schema.registry.ssl.endpoint.identification.algorithm = https

2678 schema.registry.ssl.engine.factory.class = null

2679 schema.registry.ssl.key.password = null

2680 schema.registry.ssl.keymanager.algorithm = SunX509

2681 schema.registry.ssl.keystore.certificate.chain = null

2682 schema.registry.ssl.keystore.key = null

2683 schema.registry.ssl.keystore.location = null

2684 schema.registry.ssl.keystore.password = null

2685 schema.registry.ssl.keystore.type = JKS

2686 schema.registry.ssl.protocol = TLSv1.3

2687 schema.registry.ssl.provider = null

2688 schema.registry.ssl.secure.random.implementation = null

2689 schema.registry.ssl.trustmanager.algorithm = PKIX

2690 schema.registry.ssl.truststore.certificates = null

2691 schema.registry.ssl.truststore.location = null

2692 schema.registry.ssl.truststore.password = null

2693 schema.registry.ssl.truststore.type = JKS

2694 schema.registry.url = []

2695 schema.registry.url.randomize = false

2696 specific.avro.key.type = null

2697 specific.avro.reader = false

2698 specific.avro.value.type = null

2699 use.latest.version = false

2700 use.latest.with.metadata = null

2701 use.schema.id = -1

2702 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2703

270422:08:30.979 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2705 auto.register.schemas = true

2706 avro.reflection.allow.null = false

2707 avro.use.logical.type.converters = false

2708 basic.auth.credentials.source = URL

2709 basic.auth.user.info = [hidden]

2710 bearer.auth.cache.expiry.buffer.seconds = 300

2711 bearer.auth.client.id = null

2712 bearer.auth.client.secret = null

2713 bearer.auth.credentials.source = STATIC_TOKEN

2714 bearer.auth.custom.provider.class = null

2715 bearer.auth.identity.pool.id = null

2716 bearer.auth.issuer.endpoint.url = null

2717 bearer.auth.logical.cluster = null

2718 bearer.auth.scope = null

2719 bearer.auth.scope.claim.name = scope

2720 bearer.auth.sub.claim.name = sub

2721 bearer.auth.token = [hidden]

2722 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2723 http.connect.timeout.ms = 60000

2724 http.read.timeout.ms = 60000

2725 id.compatibility.strict = true

2726 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2727 latest.cache.size = 1000

2728 latest.cache.ttl.sec = -1

2729 latest.compatibility.strict = true

2730 max.retries = 3

2731 max.schemas.per.subject = 1000

2732 normalize.schemas = false

2733 propagate.schema.tags = false

2734 proxy.host =

2735 proxy.port = -1

2736 retries.max.wait.ms = 20000

2737 retries.wait.ms = 1000

2738 rule.actions = []

2739 rule.executors = []

2740 rule.service.loader.enable = true

2741 schema.format = null

2742 schema.reflection = false

2743 schema.registry.basic.auth.user.info = [hidden]

2744 schema.registry.ssl.cipher.suites = null

2745 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2746 schema.registry.ssl.endpoint.identification.algorithm = https

2747 schema.registry.ssl.engine.factory.class = null

2748 schema.registry.ssl.key.password = null

2749 schema.registry.ssl.keymanager.algorithm = SunX509

2750 schema.registry.ssl.keystore.certificate.chain = null

2751 schema.registry.ssl.keystore.key = null

2752 schema.registry.ssl.keystore.location = null

2753 schema.registry.ssl.keystore.password = null

2754 schema.registry.ssl.keystore.type = JKS

2755 schema.registry.ssl.protocol = TLSv1.3

2756 schema.registry.ssl.provider = null

2757 schema.registry.ssl.secure.random.implementation = null

2758 schema.registry.ssl.trustmanager.algorithm = PKIX

2759 schema.registry.ssl.truststore.certificates = null

2760 schema.registry.ssl.truststore.location = null

2761 schema.registry.ssl.truststore.password = null

2762 schema.registry.ssl.truststore.type = JKS

2763 schema.registry.url = []

2764 schema.registry.url.randomize = false

2765 specific.avro.key.type = null

2766 specific.avro.reader = false

2767 specific.avro.value.type = null

2768 use.latest.version = false

2769 use.latest.with.metadata = null

2770 use.schema.id = -1

2771 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2772

2773[info] - can create a deserializer (11 milliseconds)

2774[info] - raises schema errors (4 milliseconds)

277522:08:30.990 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2776 auto.register.schemas = true

2777 avro.reflection.allow.null = false

2778 avro.use.logical.type.converters = false

2779 basic.auth.credentials.source = URL

2780 basic.auth.user.info = [hidden]

2781 bearer.auth.cache.expiry.buffer.seconds = 300

2782 bearer.auth.client.id = null

2783 bearer.auth.client.secret = null

2784 bearer.auth.credentials.source = STATIC_TOKEN

2785 bearer.auth.custom.provider.class = null

2786 bearer.auth.identity.pool.id = null

2787 bearer.auth.issuer.endpoint.url = null

2788 bearer.auth.logical.cluster = null

2789 bearer.auth.scope = null

2790 bearer.auth.scope.claim.name = scope

2791 bearer.auth.sub.claim.name = sub

2792 bearer.auth.token = [hidden]

2793 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2794 http.connect.timeout.ms = 60000

2795 http.read.timeout.ms = 60000

2796 id.compatibility.strict = true

2797 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2798 latest.cache.size = 1000

2799 latest.cache.ttl.sec = -1

2800 latest.compatibility.strict = true

2801 max.retries = 3

2802 max.schemas.per.subject = 1000

2803 normalize.schemas = false

2804 propagate.schema.tags = false

2805 proxy.host =

2806 proxy.port = -1

2807 retries.max.wait.ms = 20000

2808 retries.wait.ms = 1000

2809 rule.actions = []

2810 rule.executors = []

2811 rule.service.loader.enable = true

2812 schema.format = null

2813 schema.reflection = false

2814 schema.registry.basic.auth.user.info = [hidden]

2815 schema.registry.ssl.cipher.suites = null

2816 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2817 schema.registry.ssl.endpoint.identification.algorithm = https

2818 schema.registry.ssl.engine.factory.class = null

2819 schema.registry.ssl.key.password = null

2820 schema.registry.ssl.keymanager.algorithm = SunX509

2821 schema.registry.ssl.keystore.certificate.chain = null

2822 schema.registry.ssl.keystore.key = null

2823 schema.registry.ssl.keystore.location = null

2824 schema.registry.ssl.keystore.password = null

2825 schema.registry.ssl.keystore.type = JKS

2826 schema.registry.ssl.protocol = TLSv1.3

2827 schema.registry.ssl.provider = null

2828 schema.registry.ssl.secure.random.implementation = null

2829 schema.registry.ssl.trustmanager.algorithm = PKIX

2830 schema.registry.ssl.truststore.certificates = null

2831 schema.registry.ssl.truststore.location = null

2832 schema.registry.ssl.truststore.password = null

2833 schema.registry.ssl.truststore.type = JKS

2834 schema.registry.url = []

2835 schema.registry.url.randomize = false

2836 specific.avro.key.type = null

2837 specific.avro.reader = false

2838 specific.avro.value.type = null

2839 use.latest.version = false

2840 use.latest.with.metadata = null

2841 use.schema.id = -1

2842 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2843

2844[info] - raises IllegalArgumentException if the data is null (7 milliseconds)

2845[info] - toString (2 milliseconds)

2846Starting build for ProjectRef(file:/build/repo/,vulcan-testkit-munit) (fs2-kafka-vulcan-testkit-munit)... [2/4]

2847Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

2848Starting build for ProjectRef(file:/build/repo/,core) (fs2-kafka)... [3/4]

2849Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

2850[info] TimestampLawsSpec:

2851[info] - Timestamp.eqLaws.eq.antisymmetry eq (59 milliseconds)

2852[info] - Timestamp.eqLaws.eq.reflexivity eq (6 milliseconds)

2853[info] - Timestamp.eqLaws.eq.symmetry eq (16 milliseconds)

2854[info] - Timestamp.eqLaws.eq.transitivity eq (7 milliseconds)

2855[info] UnexpectedTopicExceptionSpec:

2856[info] UnexpectedTopicException

2857[info] - should have expected message and toString (9 milliseconds)

2858[info] IsolationLevelSpec:

2859[info] IsolationLevel

2860[info] - should have toString matching name (2 milliseconds)

2861[info] JitterSpec:

2862[info] Jitter#default

2863[info] - should always apply jitter on values (256 milliseconds)

2864[info] Jitter#none

2865[info] - should never apply jitter on values (2 milliseconds)

2866[info] SerializationExceptionSpec:

2867[info] SerializationException

2868[info] - should have expected message and toString (2 milliseconds)

2869[info] ConsumerRecordLawsSpec:

2870[info] - ConsumerRecord.eqLaws.eq.antisymmetry eq (78 milliseconds)

2871[info] - ConsumerRecord.eqLaws.eq.reflexivity eq (18 milliseconds)

2872[info] - ConsumerRecord.eqLaws.eq.symmetry eq (26 milliseconds)

2873[info] - ConsumerRecord.eqLaws.eq.transitivity eq (19 milliseconds)

2874[info] - ConsumerRecord.traverseLaws.traverse.collectFirst reference (23 milliseconds)

2875[info] - ConsumerRecord.traverseLaws.traverse.collectFirstSome reference (12 milliseconds)

2876[info] - ConsumerRecord.traverseLaws.traverse.contains all elements from itself (9 milliseconds)

2877[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with exists (8 milliseconds)

2878[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with forall (11 milliseconds)

2879[info] - ConsumerRecord.traverseLaws.traverse.covariant composition (9 milliseconds)

2880[info] - ConsumerRecord.traverseLaws.traverse.covariant identity (11 milliseconds)

2881[info] - ConsumerRecord.traverseLaws.traverse.dropWhile_ reference (9 milliseconds)

2882[info] - ConsumerRecord.traverseLaws.traverse.exists consistent with find (9 milliseconds)

2883[info] - ConsumerRecord.traverseLaws.traverse.exists is lazy (8 milliseconds)

2884[info] - ConsumerRecord.traverseLaws.traverse.filter_ reference (7 milliseconds)

2885[info] - ConsumerRecord.traverseLaws.traverse.fold reference (8 milliseconds)

2886[info] - ConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (10 milliseconds)

2887[info] - ConsumerRecord.traverseLaws.traverse.foldM identity (16 milliseconds)

2888[info] - ConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (8 milliseconds)

2889[info] - ConsumerRecord.traverseLaws.traverse.foldRight is lazy (5 milliseconds)

2890[info] - ConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (11 milliseconds)

2891[info] - ConsumerRecord.traverseLaws.traverse.forall consistent with exists (4 milliseconds)

2892[info] - ConsumerRecord.traverseLaws.traverse.forall is lazy (4 milliseconds)

2893[info] - ConsumerRecord.traverseLaws.traverse.forall true if empty (6 milliseconds)

2894[info] - ConsumerRecord.traverseLaws.traverse.get reference (11 milliseconds)

2895[info] - ConsumerRecord.traverseLaws.traverse.invariant composition (9 milliseconds)

2896[info] - ConsumerRecord.traverseLaws.traverse.invariant identity (5 milliseconds)

2897[info] - ConsumerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (7 milliseconds)

2898[info] - ConsumerRecord.traverseLaws.traverse.nonEmpty reference (4 milliseconds)

2899[info] - ConsumerRecord.traverseLaws.traverse.ordered consistency (6 milliseconds)

2900[info] - ConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (6 milliseconds)

2901[info] - ConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (8 milliseconds)

2902[info] - ConsumerRecord.traverseLaws.traverse.takeWhile_ reference (6 milliseconds)

2903[info] - ConsumerRecord.traverseLaws.traverse.toList reference (6 milliseconds)

2904[info] - ConsumerRecord.traverseLaws.traverse.traverse derive foldMap (13 milliseconds)

2905[info] - ConsumerRecord.traverseLaws.traverse.traverse identity (4 milliseconds)

2906[info] - ConsumerRecord.traverseLaws.traverse.traverse order consistency (5 milliseconds)

2907[info] - ConsumerRecord.traverseLaws.traverse.traverse parallel composition (9 milliseconds)

2908[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (33 milliseconds)

2909[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (6 milliseconds)

2910[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (9 milliseconds)

2911[info] - ConsumerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (7 milliseconds)

2912[info] - ConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (7 milliseconds)

2913[info] - ConsumerRecord.traverseLaws.traverse.traverse ref updated (6 milliseconds)

2914[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (5 milliseconds)

2915[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (5 milliseconds)

2916[info] - ConsumerRecord.traverseLaws.traverse.traverse sequential composition (13 milliseconds)

2917[info] - ConsumerRecord.traverseLaws.traverse.traverse traverseTap (5 milliseconds)

2918[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (4 milliseconds)

2919[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (6 milliseconds)

2920[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (6 milliseconds)

2921[info] - ConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (4 milliseconds)

2922[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (5 milliseconds)

2923[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (5 milliseconds)

2924[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (3 milliseconds)

2925[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (4 milliseconds)

2926[info] - ConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (4 milliseconds)

2927[info] - ConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (4 milliseconds)

2928[info] - ConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (12 milliseconds)

2929[info] - ConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (5 milliseconds)

2930[info] CommitTimeoutExceptionSpec:

2931[info] CommitTimeoutException

2932[info] - should have expected message and toString (19 milliseconds)

2933[info] TimestampSpec:

2934[info] Timeout#createTime

2935[info] - should have a createTime (5 milliseconds)

2936[info] - should not have a logAppendTime (0 milliseconds)

2937[info] - should not have an unknownTime (1 millisecond)

2938[info] - should include the createTime in toString (7 milliseconds)

2939[info] Timeout#logAppendTime

2940[info] - should have a logAppendTime (1 millisecond)

2941[info] - should not have a createTime (3 milliseconds)

2942[info] - should not have an unknownTime (1 millisecond)

2943[info] - should include the logAppendTime in toString (2 milliseconds)

2944[info] Timeout#unknownTime

2945[info] - should not have a logAppendTime (1 millisecond)

2946[info] - should not have a createTime (1 millisecond)

2947[info] - should have an unknownTime (5 milliseconds)

2948[info] - should include the unknownTime in toString (2 milliseconds)

2949[info] Timestamp#none

2950[info] - should not have createTime (1 millisecond)

2951[info] - should not have logAppendTime (0 milliseconds)

2952[info] - should not have unknownTime (0 milliseconds)

2953[info] - should be empty (0 milliseconds)

2954[info] - should not include any time in toString (0 milliseconds)

2955[info] CommittableConsumerRecordSpec:

2956[info] CommittableConsumerRecord

2957[info] - should have a Show instance and matching toString (4 milliseconds)

2958[info] KafkaSpec:

2959[info] commitBatchWithin

2960[info] - should batch commit according specified arguments (143 milliseconds)

2961[info] ProducerRecordLawsSpec:

2962[info] - ProducerRecord.eqLaws.eq.antisymmetry eq (7 milliseconds)

2963[info] - ProducerRecord.eqLaws.eq.reflexivity eq (2 milliseconds)

2964[info] - ProducerRecord.eqLaws.eq.symmetry eq (5 milliseconds)

2965[info] - ProducerRecord.eqLaws.eq.transitivity eq (5 milliseconds)

2966[info] - ProducerRecord.traverseLaws.traverse.collectFirst reference (5 milliseconds)

2967[info] - ProducerRecord.traverseLaws.traverse.collectFirstSome reference (4 milliseconds)

2968[info] - ProducerRecord.traverseLaws.traverse.contains all elements from itself (7 milliseconds)

2969[info] - ProducerRecord.traverseLaws.traverse.contains consistent with exists (6 milliseconds)

2970[info] - ProducerRecord.traverseLaws.traverse.contains consistent with forall (4 milliseconds)

2971[info] - ProducerRecord.traverseLaws.traverse.covariant composition (4 milliseconds)

2972[info] - ProducerRecord.traverseLaws.traverse.covariant identity (6 milliseconds)

2973[info] - ProducerRecord.traverseLaws.traverse.dropWhile_ reference (5 milliseconds)

2974[info] - ProducerRecord.traverseLaws.traverse.exists consistent with find (3 milliseconds)

2975[info] - ProducerRecord.traverseLaws.traverse.exists is lazy (2 milliseconds)

2976[info] - ProducerRecord.traverseLaws.traverse.filter_ reference (4 milliseconds)

2977[info] - ProducerRecord.traverseLaws.traverse.fold reference (4 milliseconds)

2978[info] - ProducerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (4 milliseconds)

2979[info] - ProducerRecord.traverseLaws.traverse.foldM identity (9 milliseconds)

2980[info] - ProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (6 milliseconds)

2981[info] - ProducerRecord.traverseLaws.traverse.foldRight is lazy (3 milliseconds)

2982[info] - ProducerRecord.traverseLaws.traverse.foldRightDefer consistency (5 milliseconds)

2983[info] - ProducerRecord.traverseLaws.traverse.forall consistent with exists (3 milliseconds)

2984[info] - ProducerRecord.traverseLaws.traverse.forall is lazy (5 milliseconds)

2985[info] - ProducerRecord.traverseLaws.traverse.forall true if empty (4 milliseconds)

2986[info] - ProducerRecord.traverseLaws.traverse.get reference (5 milliseconds)

2987[info] - ProducerRecord.traverseLaws.traverse.invariant composition (7 milliseconds)

2988[info] - ProducerRecord.traverseLaws.traverse.invariant identity (5 milliseconds)

2989[info] - ProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (4 milliseconds)

2990[info] - ProducerRecord.traverseLaws.traverse.nonEmpty reference (2 milliseconds)

2991[info] - ProducerRecord.traverseLaws.traverse.ordered consistency (3 milliseconds)

2992[info] - ProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (2 milliseconds)

2993[info] - ProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (4 milliseconds)

2994[info] - ProducerRecord.traverseLaws.traverse.takeWhile_ reference (3 milliseconds)

2995[info] - ProducerRecord.traverseLaws.traverse.toList reference (2 milliseconds)

2996[info] - ProducerRecord.traverseLaws.traverse.traverse derive foldMap (4 milliseconds)

2997[info] - ProducerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

2998[info] - ProducerRecord.traverseLaws.traverse.traverse order consistency (2 milliseconds)

2999[info] - ProducerRecord.traverseLaws.traverse.traverse parallel composition (3 milliseconds)

3000[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (6 milliseconds)

3001[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (4 milliseconds)

3002[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (3 milliseconds)

3003[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (4 milliseconds)

3004[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (4 milliseconds)

3005[info] - ProducerRecord.traverseLaws.traverse.traverse ref updated (2 milliseconds)

3006[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (3 milliseconds)

3007[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (8 milliseconds)

3008[info] - ProducerRecord.traverseLaws.traverse.traverse sequential composition (3 milliseconds)

3009[info] - ProducerRecord.traverseLaws.traverse.traverse traverseTap (2 milliseconds)

3010[info] - ProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (3 milliseconds)

3011[info] - ProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (3 milliseconds)

3012[info] - ProducerRecord.traverseLaws.traverse.unordered traverse sequential composition (3 milliseconds)

3013[info] - ProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (2 milliseconds)

3014[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (2 milliseconds)

3015[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (3 milliseconds)

3016[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (2 milliseconds)

3017[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (2 milliseconds)

3018[info] - ProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (3 milliseconds)

3019[info] - ProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (2 milliseconds)

3020[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (5 milliseconds)

3021[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 milliseconds)

3022[info] AutoOffsetResetSpec:

3023[info] AutoOffsetReset

3024[info] - should have toString matching name (4 milliseconds)

3025[info] ConsumerSettingsSpec:

3026[info] ConsumerSettings

3027[info] - should be able to set a custom blocking context (5 milliseconds)

3028[info] - should provide withBootstrapServers (0 milliseconds)

3029[info] - should provide withAutoOffsetReset (0 milliseconds)

3030[info] - should provide withAllowAutoCreateTopics (0 milliseconds)

3031[info] - should provide withClientRack (0 milliseconds)

3032[info] - should provide withClientId (0 milliseconds)

3033[info] - should provide withGroupId (0 milliseconds)

3034[info] - should provide withGroupInstanceId (1 millisecond)

3035[info] - should provide withMaxPollRecords (0 milliseconds)

3036[info] - should provide withMaxPollInterval (0 milliseconds)

3037[info] - should provide withSessionTimeout (0 milliseconds)

3038[info] - should provide withHeartbeatInterval (0 milliseconds)

3039[info] - should provide withEnableAutoCommit (1 millisecond)

3040[info] - should provide withAutoCommitInterval (1 millisecond)

3041[info] - should provide withRequestTimeout (0 milliseconds)

3042[info] - should provide withDefaultApiTimeout (0 milliseconds)

3043[info] - should provide withIsolationLevel (1 millisecond)

3044[info] - should provide withProperty (0 milliseconds)

3045[info] - should provide withProperties (1 millisecond)

3046[info] - should provide withCloseTimeout (1 millisecond)

3047[info] - should provide withCommitTimeout (0 milliseconds)

3048[info] - should provide withPollInterval (1 millisecond)

3049[info] - should provide withPollTimeout (1 millisecond)

3050[info] - should provide withCommitRecovery (0 milliseconds)

3051[info] - should provide withRecordMetadata (1 millisecond)

3052[info] - should provide withMaxPrefetchBatches (1 millisecond)

3053[info] - should be able to create with and without deserializer creation effects (1 millisecond)

3054[info] - should be able to implicitly create with and without deserializer creation effects (6 milliseconds)

3055[info] - should have a Show instance and matching toString (5 milliseconds)

3056[info] ConsumerShutdownExceptionSpec:

3057[info] ConsumerShutdownException

3058[info] - should have expected message and toString (1 millisecond)

3059[info] HeaderSerializerSpec:

3060[info] - HeaderSerializer.contravariant.contravariant composition (82 milliseconds)

3061[info] - HeaderSerializer.contravariant.contravariant identity (57 milliseconds)

3062[info] - HeaderSerializer.contravariant.invariant composition (52 milliseconds)

3063[info] - HeaderSerializer.contravariant.invariant identity (39 milliseconds)

3064[info] - HeaderSerializer#mapBytes (9 milliseconds)

3065[info] - HeaderSerializer#const (2 milliseconds)

3066[info] - HeaderSerializer#asNull (2 milliseconds)

3067[info] - HeaderSerializer#empty (2 milliseconds)

3068[info] - HeaderSerializer#option (2 milliseconds)

3069[info] - HeaderSerializer#unit (0 milliseconds)

3070[info] - HeaderSerializer#toString (0 milliseconds)

3071[info] - HeaderSerializer#string (7 milliseconds)

3072[info] - HeaderSerializer#uuid (4 milliseconds)

3073[info] - HeaderSerializer#double (3 milliseconds)

3074[info] - HeaderSerializer#float (3 milliseconds)

3075[info] - HeaderSerializer#int (2 milliseconds)

3076[info] - HeaderSerializer#long (2 milliseconds)

3077[info] - HeaderSerializer#short (3 milliseconds)

3078[info] HeadersLawsSpec:

3079[info] - Headers.eqLaws.eq.antisymmetry eq (4 milliseconds)

3080[info] - Headers.eqLaws.eq.reflexivity eq (2 milliseconds)

3081[info] - Headers.eqLaws.eq.symmetry eq (2 milliseconds)

3082[info] - Headers.eqLaws.eq.transitivity eq (3 milliseconds)

3083[info] CommittableOffsetBatchSpec:

3084[info] CommittableOffsetBatch#empty

3085[info] - should have no offsets (0 milliseconds)

3086[info] - should return updated offset as batch (2 milliseconds)

3087[info] CommittableOffsetBatch#updated

3088[info] - should include the provided offset (9 milliseconds)

3089[info] - should override using the provided offset (15 milliseconds)

3090[info] - should be able to update with batch (9 milliseconds)

3091[info] CommittableOffsetBatch#toString

3092[info] - should provide a Show instance and matching toString (3 milliseconds)

3093[info] ProducerSettingsSpec:

3094[info] ProducerSettings

3095[info] - should provide apply (0 milliseconds)

3096[info] - should provide withBootstrapServers (0 milliseconds)

3097[info] - should provide withAcks (1 millisecond)

3098[info] - should provide withBatchSize (1 millisecond)

3099[info] - should provide withClientId (0 milliseconds)

3100[info] - should provide withRetries (0 milliseconds)

3101[info] - should provide withMaxInFlightRequestsPerConnection (0 milliseconds)

3102[info] - should provide withEnableIdempotence (0 milliseconds)

3103[info] - should provide withLinger (0 milliseconds)

3104[info] - should provide withRequestTimeout (0 milliseconds)

3105[info] - should provide withDeliveryTimeout (0 milliseconds)

3106[info] - should provide withProperty/withProperties (1 millisecond)

3107[info] - should provide withCloseTimeout (0 milliseconds)

3108[info] - should have a Show instance and matching toString (0 milliseconds)

3109[info] - should be able to create with and without serializer creation effects (0 milliseconds)

3110[info] - should be able to implicitly create with and without serializer creation effects (2 milliseconds)

3111[info] - should be able to set a custom blocking context (0 milliseconds)

3112[info] - should provide failFastProduce default value (1 millisecond)

3113[info] - should be able to set failFastProduce (0 milliseconds)

3114[info] ConsumerRecordSpec:

3115[info] ConsumerRecord#fromJava

3116[info] - should convert timestamps (7 milliseconds)

3117[info] - should convert serialized key size (3 milliseconds)

3118[info] - should convert serialized value size (2 milliseconds)

3119[info] - should convert leader epoch (4 milliseconds)

3120[info] ConsumerRecord#toString

3121[info] - should include headers when present (1 millisecond)

3122[info] - should include timestamp if present (0 milliseconds)

3123[info] - should include serialized key size if present (0 milliseconds)

3124[info] - should include serialized value size if present (0 milliseconds)

3125[info] - should include leader epoch if present (0 milliseconds)

3126[info] AcksSpec:

3127[info] Acks

3128[info] - should have toString matching name (0 milliseconds)

3129[info] CommitRecoverySpec:

3130[info] CommitRecovery#Default

3131[info] - should retry org.apache.kafka.clients.consumer.RetriableCommitFailedException: retriable with jittered exponential backoff and fixed rate (16 milliseconds)

3132[info] - should retry org.apache.kafka.common.errors.RebalanceInProgressException with jittered exponential backoff and fixed rate (2 milliseconds)

3133[info] - should not recover non-retriable exceptions (1 millisecond)

3134[info] - should have Default as String representation (0 milliseconds)

3135[info] CommitRecovery#None

3136[info] - should not recover any exceptions (2 milliseconds)

3137[info] - should have None as String representation (1 millisecond)

3138[info] CommittableOffsetLawsSpec:

3139[info] - CommittableOffset.eqLaws.eq.antisymmetry eq (2 milliseconds)

3140[info] - CommittableOffset.eqLaws.eq.reflexivity eq (1 millisecond)

3141[info] - CommittableOffset.eqLaws.eq.symmetry eq (3 milliseconds)

3142[info] - CommittableOffset.eqLaws.eq.transitivity eq (3 milliseconds)

3143[info] CommittableProducerRecordsLawsSpec:

3144[info] - CommittableProducerRecord.eqLaws.eq.antisymmetry eq (5 milliseconds)

3145[info] - CommittableProducerRecord.eqLaws.eq.reflexivity eq (3 milliseconds)

3146[info] - CommittableProducerRecord.eqLaws.eq.symmetry eq (5 milliseconds)

3147[info] - CommittableProducerRecord.eqLaws.eq.transitivity eq (6 milliseconds)

3148[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirst reference (6 milliseconds)

3149[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirstSome reference (4 milliseconds)

3150[info] - CommittableProducerRecord.traverseLaws.traverse.contains all elements from itself (7 milliseconds)

3151[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with exists (3 milliseconds)

3152[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with forall (5 milliseconds)

3153[info] - CommittableProducerRecord.traverseLaws.traverse.covariant composition (13 milliseconds)

3154[info] - CommittableProducerRecord.traverseLaws.traverse.covariant identity (5 milliseconds)

3155[info] - CommittableProducerRecord.traverseLaws.traverse.dropWhile_ reference (4 milliseconds)

3156[info] - CommittableProducerRecord.traverseLaws.traverse.exists consistent with find (4 milliseconds)

3157[info] - CommittableProducerRecord.traverseLaws.traverse.exists is lazy (3 milliseconds)

3158[info] - CommittableProducerRecord.traverseLaws.traverse.filter_ reference (2 milliseconds)

3159[info] - CommittableProducerRecord.traverseLaws.traverse.fold reference (3 milliseconds)

3160[info] - CommittableProducerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (8 milliseconds)

3161[info] - CommittableProducerRecord.traverseLaws.traverse.foldM identity (9 milliseconds)

3162[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (7 milliseconds)

3163[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight is lazy (2 milliseconds)

3164[info] - CommittableProducerRecord.traverseLaws.traverse.foldRightDefer consistency (4 milliseconds)

3165[info] - CommittableProducerRecord.traverseLaws.traverse.forall consistent with exists (4 milliseconds)

3166[info] - CommittableProducerRecord.traverseLaws.traverse.forall is lazy (4 milliseconds)

3167[info] - CommittableProducerRecord.traverseLaws.traverse.forall true if empty (5 milliseconds)

3168[info] - CommittableProducerRecord.traverseLaws.traverse.get reference (5 milliseconds)

3169[info] - CommittableProducerRecord.traverseLaws.traverse.invariant composition (5 milliseconds)

3170[info] - CommittableProducerRecord.traverseLaws.traverse.invariant identity (5 milliseconds)

3171[info] - CommittableProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (5 milliseconds)

3172[info] - CommittableProducerRecord.traverseLaws.traverse.nonEmpty reference (3 milliseconds)

3173[info] - CommittableProducerRecord.traverseLaws.traverse.ordered consistency (3 milliseconds)

3174[info] - CommittableProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (4 milliseconds)

3175[info] - CommittableProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (5 milliseconds)

3176[info] - CommittableProducerRecord.traverseLaws.traverse.takeWhile_ reference (3 milliseconds)

3177[info] - CommittableProducerRecord.traverseLaws.traverse.toList reference (2 milliseconds)

3178[info] - CommittableProducerRecord.traverseLaws.traverse.traverse derive foldMap (10 milliseconds)

3179[info] - CommittableProducerRecord.traverseLaws.traverse.traverse identity (5 milliseconds)

3180[info] - CommittableProducerRecord.traverseLaws.traverse.traverse order consistency (5 milliseconds)

3181[info] - CommittableProducerRecord.traverseLaws.traverse.traverse parallel composition (6 milliseconds)

3182[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (9 milliseconds)

3183[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (7 milliseconds)

3184[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (7 milliseconds)

3185[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (4 milliseconds)

3186[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (7 milliseconds)

3187[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref updated (6 milliseconds)

3188[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (12 milliseconds)

3189[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (11 milliseconds)

3190[info] - CommittableProducerRecord.traverseLaws.traverse.traverse sequential composition (9 milliseconds)

3191[info] - CommittableProducerRecord.traverseLaws.traverse.traverse traverseTap (6 milliseconds)

3192[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (5 milliseconds)

3193[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (7 milliseconds)

3194[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse sequential composition (7 milliseconds)

3195[info] - CommittableProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (3 milliseconds)

3196[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (4 milliseconds)

3197[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (5 milliseconds)

3198[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (4 milliseconds)

3199[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (5 milliseconds)

3200[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (4 milliseconds)

3201[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (6 milliseconds)

3202[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (5 milliseconds)

3203[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 milliseconds)

3204[info] HeaderDeserializerSpec:

3205[info] - HeaderDeserializer.monad.ap consistent with product + map (49 milliseconds)

3206[info] - HeaderDeserializer.monad.applicative homomorphism (32 milliseconds)

3207[info] - HeaderDeserializer.monad.applicative identity (34 milliseconds)

3208[info] - HeaderDeserializer.monad.applicative interchange (30 milliseconds)

3209[info] - HeaderDeserializer.monad.applicative map (33 milliseconds)

3210[info] - HeaderDeserializer.monad.applicative unit (27 milliseconds)

3211[info] - HeaderDeserializer.monad.apply composition (29 milliseconds)

3212[info] - HeaderDeserializer.monad.covariant composition (40 milliseconds)

3213[info] - HeaderDeserializer.monad.covariant identity (26 milliseconds)

3214[info] - HeaderDeserializer.monad.flatMap associativity (31 milliseconds)

3215[info] - HeaderDeserializer.monad.flatMap consistent apply (32 milliseconds)

3216[info] - HeaderDeserializer.monad.flatMap from tailRecM consistency (28 milliseconds)

3217[info] - HeaderDeserializer.monad.invariant composition (31 milliseconds)

3218[info] - HeaderDeserializer.monad.invariant identity (32 milliseconds)

3219[info] - HeaderDeserializer.monad.map flatMap coherence (27 milliseconds)

3220[info] - HeaderDeserializer.monad.map2/map2Eval consistency (26 milliseconds)

3221[info] - HeaderDeserializer.monad.map2/product-map consistency (28 milliseconds)

3222[info] - HeaderDeserializer.monad.mapOrKeepToMapEquivalence (26 milliseconds)

3223[info] - HeaderDeserializer.monad.monad left identity (16 milliseconds)

3224[info] - HeaderDeserializer.monad.monad right identity (22 milliseconds)

3225[info] - HeaderDeserializer.monad.monoidal left identity (21 milliseconds)

3226[info] - HeaderDeserializer.monad.monoidal right identity (18 milliseconds)

3227[info] - HeaderDeserializer.monad.mproduct consistent flatMap (37 milliseconds)

3228[info] - HeaderDeserializer.monad.productL consistent map2 (17 milliseconds)

3229[info] - HeaderDeserializer.monad.productR consistent map2 (16 milliseconds)

3230[info] - HeaderDeserializer.monad.replicateA_ consistent with replicateA.void (41 milliseconds)

3231[info] - HeaderDeserializer.monad.semigroupal associativity (43 milliseconds)

3232[info] - HeaderDeserializer.monad.tailRecM consistent flatMap (29 milliseconds)

3233[info] - HeaderDeserializer.monad.tailRecM stack safety (45 milliseconds)

3234[info] - HeaderDeserializer#delay (2 milliseconds)

3235[info] - HeaderDeserializer#option (1 millisecond)

3236[info] - HeaderDeserializer#unit (1 millisecond)

3237[info] - HeaderDeserializer#toString (1 millisecond)

3238[info] CommittableConsumerRecordLawsSpec:

3239[info] - CommittableConsumerRecord.eqLaws.eq.antisymmetry eq (2 milliseconds)

3240[info] - CommittableConsumerRecord.eqLaws.eq.reflexivity eq (2 milliseconds)

3241[info] - CommittableConsumerRecord.eqLaws.eq.symmetry eq (3 milliseconds)

3242[info] - CommittableConsumerRecord.eqLaws.eq.transitivity eq (3 milliseconds)

3243[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirst reference (2 milliseconds)

3244[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirstSome reference (2 milliseconds)

3245[info] - CommittableConsumerRecord.traverseLaws.traverse.contains all elements from itself (2 milliseconds)

3246[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with exists (2 milliseconds)

3247[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with forall (3 milliseconds)

3248[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant composition (2 milliseconds)

3249[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant identity (1 millisecond)

3250[info] - CommittableConsumerRecord.traverseLaws.traverse.dropWhile_ reference (1 millisecond)

3251[info] - CommittableConsumerRecord.traverseLaws.traverse.exists consistent with find (2 milliseconds)

3252[info] - CommittableConsumerRecord.traverseLaws.traverse.exists is lazy (2 milliseconds)

3253[info] - CommittableConsumerRecord.traverseLaws.traverse.filter_ reference (1 millisecond)

3254[info] - CommittableConsumerRecord.traverseLaws.traverse.fold reference (1 millisecond)

3255[info] - CommittableConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (3 milliseconds)

3256[info] - CommittableConsumerRecord.traverseLaws.traverse.foldM identity (4 milliseconds)

3257[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (3 milliseconds)

3258[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight is lazy (2 milliseconds)

3259[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (4 milliseconds)

3260[info] - CommittableConsumerRecord.traverseLaws.traverse.forall consistent with exists (1 millisecond)

3261[info] - CommittableConsumerRecord.traverseLaws.traverse.forall is lazy (2 milliseconds)

3262[info] - CommittableConsumerRecord.traverseLaws.traverse.forall true if empty (2 milliseconds)

3263[info] - CommittableConsumerRecord.traverseLaws.traverse.get reference (2 milliseconds)

3264[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant composition (2 milliseconds)

3265[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant identity (3 milliseconds)

3266[info] - CommittableConsumerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (3 milliseconds)

3267[info] - CommittableConsumerRecord.traverseLaws.traverse.nonEmpty reference (3 milliseconds)

3268[info] - CommittableConsumerRecord.traverseLaws.traverse.ordered consistency (3 milliseconds)

3269[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (3 milliseconds)

3270[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (3 milliseconds)

3271[info] - CommittableConsumerRecord.traverseLaws.traverse.takeWhile_ reference (4 milliseconds)

3272[info] - CommittableConsumerRecord.traverseLaws.traverse.toList reference (3 milliseconds)

3273[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse derive foldMap (3 milliseconds)

3274[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

3275[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse order consistency (3 milliseconds)

3276[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse parallel composition (3 milliseconds)

3277[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (4 milliseconds)

3278[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (4 milliseconds)

3279[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (3 milliseconds)

3280[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (2 milliseconds)

3281[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (2 milliseconds)

3282[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref updated (3 milliseconds)

3283[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (3 milliseconds)

3284[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (2 milliseconds)

3285[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse sequential composition (3 milliseconds)

3286[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse traverseTap (3 milliseconds)

3287[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (2 milliseconds)

3288[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (3 milliseconds)

3289[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (3 milliseconds)

3290[info] - CommittableConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (2 milliseconds)

3291[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (2 milliseconds)

3292[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (2 milliseconds)

3293[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (4 milliseconds)

3294[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (2 milliseconds)

3295[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (3 milliseconds)

3296[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (3 milliseconds)

3297[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (2 milliseconds)

3298[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 milliseconds)

3299[info] DeserializationExceptionSpec:

3300[info] DeserializationException

3301[info] - should have expected message and toString (3 milliseconds)

3302[info] HeaderSpec:

3303[info] Header

3304[info] - toString should be Header(key -> value) (0 milliseconds)

3305[info] - should have consistent toString and Show (0 milliseconds)

3306[info] - should return the key with key (0 milliseconds)

3307[info] - should return the value with value (0 milliseconds)

3308[info] - should deserialize with as (0 milliseconds)

3309[info] - should deserialize with attemptAs (1 millisecond)

3310[info] HeaderLawsSpec:

3311[info] - Header.eqLaws.eq.antisymmetry eq (1 millisecond)

3312[info] - Header.eqLaws.eq.reflexivity eq (3 milliseconds)

3313[info] - Header.eqLaws.eq.symmetry eq (2 milliseconds)

3314[info] - Header.eqLaws.eq.transitivity eq (1 millisecond)

3315[info] SerializerSpec:

3316[info] - Serializer[IO, *].contravariant.contravariant composition (279 milliseconds)

3317[info] - Serializer[IO, *].contravariant.contravariant identity (302 milliseconds)

3318[info] - Serializer[IO, *].contravariant.invariant composition (160 milliseconds)

3319[info] - Serializer[IO, *].contravariant.invariant identity (102 milliseconds)

3320[info] - Serializer#mapBytes (8 milliseconds)

3321[info] - Serializer#apply (3 milliseconds)

3322[info] - Serializer#identity (6 milliseconds)

3323[info] - Serializer#const (2 milliseconds)

3324[info] - Serializer#defer (6 milliseconds)

3325[info] - Serializer#fail (6 milliseconds)

3326[info] - Serializer#failWith (7 milliseconds)

3327[info] - Serializer#suspend (12 milliseconds)

3328[info] - Serializer#headers (12 milliseconds)

3329[info] - Serializer#topic (10 milliseconds)

3330[info] - Serializer#topic.unknown (5 milliseconds)

3331[info] - Serializer#asNull (2 milliseconds)

3332[info] - Serializer#empty (2 milliseconds)

3333[info] - Serializer#option (9 milliseconds)

3334[info] - Serializer#unit (1 millisecond)

3335[info] - Serializer#toString (0 milliseconds)

3336[info] - Serializer#string (4 milliseconds)

3337[info] - Serializer#uuid (6 milliseconds)

3338[info] - Serializer#uuid.default (6 milliseconds)

3339[info] - Serializer#double (4 milliseconds)

3340[info] - Serializer#float (4 milliseconds)

3341[info] - Serializer#int (2 milliseconds)

3342[info] - Serializer#long (2 milliseconds)

3343[info] - Serializer#short (2 milliseconds)

3344[info] DeserializerSpec:

3345[info] - Deserializer[IO, *].monadError.ap consistent with product + map (170 milliseconds)

3346[info] - Deserializer[IO, *].monadError.applicative homomorphism (108 milliseconds)

3347[info] - Deserializer[IO, *].monadError.applicative identity (98 milliseconds)

3348[info] - Deserializer[IO, *].monadError.applicative interchange (116 milliseconds)

3349[info] - Deserializer[IO, *].monadError.applicative map (95 milliseconds)

3350[info] - Deserializer[IO, *].monadError.applicative unit (99 milliseconds)

3351[info] - Deserializer[IO, *].monadError.applicativeError adaptError pure (100 milliseconds)

3352[info] - Deserializer[IO, *].monadError.applicativeError adaptError raise (114 milliseconds)

3353[info] - Deserializer[IO, *].monadError.applicativeError attempt consistent with attemptT (90 milliseconds)

3354[info] - Deserializer[IO, *].monadError.applicativeError attempt fromEither consistent with pure (100 milliseconds)

3355[info] - Deserializer[IO, *].monadError.applicativeError handle (128 milliseconds)

3356[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError left-distributes over ap (96 milliseconds)

3357[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError right-distributes over ap (117 milliseconds)

3358[info] - Deserializer[IO, *].monadError.applicativeError handleError consistent with recover (68 milliseconds)

3359[info] - Deserializer[IO, *].monadError.applicativeError handleError pure (69 milliseconds)

3360[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith consistent with recoverWith (61 milliseconds)

3361[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith pure (89 milliseconds)

3362[info] - Deserializer[IO, *].monadError.applicativeError handleWith (71 milliseconds)

3363[info] - Deserializer[IO, *].monadError.applicativeError onError pure (68 milliseconds)

3364[info] - Deserializer[IO, *].monadError.applicativeError onError raise (72 milliseconds)

3365[info] - Deserializer[IO, *].monadError.applicativeError pure attempt (68 milliseconds)

3366[info] - Deserializer[IO, *].monadError.applicativeError raiseError attempt (63 milliseconds)

3367[info] - Deserializer[IO, *].monadError.applicativeError recover consistent with recoverWith (74 milliseconds)

3368[info] - Deserializer[IO, *].monadError.applicativeError redeem is derived from attempt and map (75 milliseconds)

3369[info] - Deserializer[IO, *].monadError.applicativeError voidError consistent with void+handleError (81 milliseconds)

3370[info] - Deserializer[IO, *].monadError.apply composition (68 milliseconds)

3371[info] - Deserializer[IO, *].monadError.covariant composition (63 milliseconds)

3372[info] - Deserializer[IO, *].monadError.covariant identity (73 milliseconds)

3373[info] - Deserializer[IO, *].monadError.flatMap associativity (73 milliseconds)

3374[info] - Deserializer[IO, *].monadError.flatMap consistent apply (69 milliseconds)

3375[info] - Deserializer[IO, *].monadError.flatMap from tailRecM consistency (77 milliseconds)

3376[info] - Deserializer[IO, *].monadError.invariant composition (71 milliseconds)

3377[info] - Deserializer[IO, *].monadError.invariant identity (75 milliseconds)

3378[info] - Deserializer[IO, *].monadError.map flatMap coherence (96 milliseconds)

3379[info] - Deserializer[IO, *].monadError.map2/map2Eval consistency (73 milliseconds)

3380[info] - Deserializer[IO, *].monadError.map2/product-map consistency (78 milliseconds)

3381[info] - Deserializer[IO, *].monadError.mapOrKeepToMapEquivalence (66 milliseconds)

3382[info] - Deserializer[IO, *].monadError.monad left identity (65 milliseconds)

3383[info] - Deserializer[IO, *].monadError.monad right identity (61 milliseconds)

3384[info] - Deserializer[IO, *].monadError.monadError ensure consistency (71 milliseconds)

3385[info] - Deserializer[IO, *].monadError.monadError ensureOr consistency (74 milliseconds)

3386[info] - Deserializer[IO, *].monadError.monadError left zero (63 milliseconds)

3387[info] - Deserializer[IO, *].monadError.monadError redeemWith is derived from attempt and flatMap (70 milliseconds)

3388[info] - Deserializer[IO, *].monadError.monadError rethrow attempt (73 milliseconds)

3389[info] - Deserializer[IO, *].monadError.monoidal left identity (69 milliseconds)

3390[info] - Deserializer[IO, *].monadError.monoidal right identity (65 milliseconds)

3391[info] - Deserializer[IO, *].monadError.mproduct consistent flatMap (133 milliseconds)

3392[info] - Deserializer[IO, *].monadError.productL consistent map2 (67 milliseconds)

3393[info] - Deserializer[IO, *].monadError.productR consistent map2 (68 milliseconds)

3394[info] - Deserializer[IO, *].monadError.replicateA_ consistent with replicateA.void (79 milliseconds)

3395[info] - Deserializer[IO, *].monadError.semigroupal associativity (77 milliseconds)

3396[info] - Deserializer[IO, *].monadError.tailRecM consistent flatMap (92 milliseconds)

3397[info] - Deserializer[IO, *].monadError.tailRecM stack safety (204 milliseconds)

3398[info] - Deserializer#attempt (7 milliseconds)

3399[info] - Deserializer#fail (4 milliseconds)

3400[info] - Deserializer#failWith (6 milliseconds)

3401[info] - Deserializer#headers (14 milliseconds)

3402[info] - Deserializer#apply (3 milliseconds)

3403[info] - Deserializer#identity (2 milliseconds)

3404[info] - Deserializer#suspend (3 milliseconds)

3405[info] - Deserializer#topic (7 milliseconds)

3406[info] - Deserializer#topic.unknown (4 milliseconds)

3407[info] - Deserializer#attempt (implicit) (5 milliseconds)

3408[info] - Deserializer#option (7 milliseconds)

3409[info] - Deserializer#unit (2 milliseconds)

3410[info] - Deserializer#toString (0 milliseconds)

3411[info] KafkaCredentialStoreSpec:

3412[info] KafkaCredentialStore

3413[info] fromPemStrings

3414[info] - should create a KafkaCredentialStore with the expected properties (1 millisecond)

3415[info] HeadersSpec:

3416[info] Headers#empty

3417[info] - should have toString as Headers() (0 milliseconds)

3418[info] - should return true for isEmpty (0 milliseconds)

3419[info] - should return false for nonEmpty (0 milliseconds)

3420[info] - should return false for exists (0 milliseconds)

3421[info] - should not find any key (1 millisecond)

3422[info] - should concat empty (0 milliseconds)

3423[info] - should concat non-empty (1 millisecond)

3424[info] - should return empty Chain from toChain (0 milliseconds)

3425[info] - should create a new Headers from append(Header) (0 milliseconds)

3426[info] - should create a new Headers from append(key, value) (0 milliseconds)

3427[info] Headers#empty.asJava

3428[info] - add(header) throws IllegalStateException (1 millisecond)

3429[info] - add(key, value) throws IllegalStateException (0 milliseconds)

3430[info] - remove throws IllegalStateException (1 millisecond)

3431[info] - lastHeader returns null (0 milliseconds)

3432[info] - headers returns empty iterable (0 milliseconds)

3433[info] - toArray returns empty array (0 milliseconds)

3434[info] - iterator.next throws NoSuchElementException (0 milliseconds)

3435[info] - iterator.hasNext returns false (0 milliseconds)

3436[info] Headers#nonEmpty.asJava

3437[info] - add(header) throws IllegalStateException (0 milliseconds)

3438[info] - add(key, value) throws IllegalStateException (0 milliseconds)

3439[info] - remove throws IllegalStateException (1 millisecond)

3440[info] - lastHeader returns last header (0 milliseconds)

3441[info] - lastHeaders returns existing header (0 milliseconds)

3442[info] - lastHeader returns null for missing key (0 milliseconds)

3443[info] - headers returns matching headers (8 milliseconds)

3444[info] - headers returns empty if no matching headers (0 milliseconds)

3445[info] - toArray returns elements (1 millisecond)

3446[info] - iterator returns elements (0 milliseconds)

3447[info] Headers#nonEmpty

3448[info] - should not be empty (0 milliseconds)

3449[info] - should be non empty (0 milliseconds)

3450[info] - should find an existing key (0 milliseconds)

3451[info] - should find the first key (0 milliseconds)

3452[info] - should return true for existing key (1 millisecond)

3453[info] - should return false for non-existing key (1 millisecond)

3454[info] - should concat empty (0 milliseconds)

3455[info] - should concat non-empty (0 milliseconds)

3456[info] - should include the headers in toString (0 milliseconds)

3457[info] - should append one more header with append(Header) (0 milliseconds)

3458[info] - should append one more header with append(key, value) (0 milliseconds)

3459[info] Headers#apply

3460[info] - returns empty for no headers (0 milliseconds)

3461[info] - returns non-empty for at least one header (0 milliseconds)

3462[info] Headers#fromChain

3463[info] - returns empty for empty chain (0 milliseconds)

3464[info] - returns non-empty for non-empty chain (0 milliseconds)

3465[info] Headers#fromSeq

3466[info] - returns empty for empty seq (0 milliseconds)

3467[info] - returns non-empty for non-empty seq (0 milliseconds)

3468[info] Headers#fromIterable

3469[info] - returns empty for empty iterable (0 milliseconds)

3470[info] - returns non-empty for non-empty iterable (0 milliseconds)

3471[info] SyntaxSpec:

3472[info] Map#filterKeysStrictValuesList

3473[info] - should be the same as toList.collect (3 milliseconds)

3474[info] KafkaHeaders#asScala

3475[info] - should convert empty (0 milliseconds)

3476[info] - should convert non-empty (1 millisecond)

3477[info] KafkaFuture.cancelable

3478[info] - should cancel future when fiber is cancelled (22 milliseconds)

3479[info] CommittableOffsetSpec:

3480[info] CommittableOffset

3481[info] - should be able to commit the offset (0 milliseconds)

3482[info] - should have a Show instance and matching toString (1 millisecond)

3483[info] AdminClientSettingsSpec:

3484[info] AdminClientSettings

3485[info] - should provide withBootstrapServers (2 milliseconds)

3486[info] - should provide withClientId (0 milliseconds)

3487[info] - should provide withReconnectBackoff (0 milliseconds)

3488[info] - should provide withReconnectBackoffMax (0 milliseconds)

3489[info] - should provide withRetryBackoff (0 milliseconds)

3490[info] - should provide withConnectionsMaxIdle (0 milliseconds)

3491[info] - should provide withRequestTimeout (0 milliseconds)

3492[info] - should provide withMetadataMaxAge (0 milliseconds)

3493[info] - should provide withRetries (0 milliseconds)

3494[info] - should provide withProperty (0 milliseconds)

3495[info] - should provide withProperties (1 millisecond)

3496[info] - should provide withCloseTimeout (0 milliseconds)

3497[info] - should have a Show instance and matching toString (7 milliseconds)

3498

3499************************

3500Build summary:

3501[{

3502 "module": "fs2-kafka",

3503 "compile": {"status": "ok", "tookMs": 234, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

3505 "test-compile": {"status": "ok", "tookMs": 138, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

3507 "publish": {"status": "ok", "tookMs": 4},

3508 "metadata": {

3509 "crossScalaVersions": ["2.12.20", "2.13.17", "3.3.6"]

3510}

3511},{

3512 "module": "fs2-kafka-vulcan",

3513 "compile": {"status": "ok", "tookMs": 347, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

3515 "test-compile": {"status": "ok", "tookMs": 346, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

3516 "test": {"status": "ok", "tookMs": 2299, "passed": 37, "failed": 0, "ignored": 0, "skipped": 0, "total": 37, "byFramework": [{"framework": "unknown", "stats": {"passed": 37, "failed": 0, "ignored": 0, "skipped": 0, "total": 37}}]},

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

3518 "metadata": {

3519 "crossScalaVersions": ["2.12.20", "2.13.17", "3.3.6"]

3520}

3521},{

3522 "module": "fs2-kafka-vulcan-testkit-munit",

3523 "compile": {"status": "ok", "tookMs": 187, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

3525 "test-compile": {"status": "ok", "tookMs": 247, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

3528 "metadata": {

3529 "crossScalaVersions": ["2.12.20", "2.13.17", "3.3.6"]

3530}

3531},{

3532 "module": "fs2-kafka",

3533 "compile": {"status": "ok", "tookMs": 49, "warnings": 1, "errors": 0, "sourceVersion": "3.8"},

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

3535 "test-compile": {"status": "ok", "tookMs": 183, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

3536 "test": {"status": "ok", "tookMs": 10645, "passed": 572, "failed": 0, "ignored": 0, "skipped": 0, "total": 572, "byFramework": [{"framework": "unknown", "stats": {"passed": 572, "failed": 0, "ignored": 0, "skipped": 0, "total": 572}}]},

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

3538 "metadata": {

3539 "crossScalaVersions": ["2.12.20", "2.13.17", "3.3.6"]

3540}

3541}]

3542************************

3543[success] Total time: 20 s, completed Jan 13, 2026, 10:08:44 PM

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

3545Checking patch build.sbt...

3546Applied patch project/plugins.sbt cleanly.

3547Applied patch build.sbt cleanly.