Build Logs

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.449s.

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/crossScalaVersions

90OpenCB::Changing crossVersion 3.7.4 -> 3.7.4 in vulcan-testkit-munit/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:

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 8, 2026, 2:59:32 AM

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 ...

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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 ...

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/BaseKafkaSpec.scala]

194[info] [patched file /build/repo/modules/core/src/test/scala/fs2/kafka/CommittableOffsetBatchSpec.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

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

200Build summary:

201[{

202 "module": "fs2-kafka",

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

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

205 "test-compile": {"status": "ok", "tookMs": 112, "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": 5},

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": 19136, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

215 "test-compile": {"status": "ok", "tookMs": 10116, "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": 638, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

225 "test-compile": {"status": "ok", "tookMs": 195, "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": 43, "warnings": 1, "errors": 0, "sourceVersion": "3.4-migration"},

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

235 "test-compile": {"status": "ok", "tookMs": 14638, "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: 66 s (0:01:06.0), completed Jan 8, 2026, 3:00:38 AM

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 1e33cadc] 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.0-RC6

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

262Try apply source patch:

263Path: build.sbt

264Pattern: val scala3 = "3.3.6"

265Replacement: val scala3 = "3.8.0-RC6"

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

267----

268Starting build for 3.8.0-RC6

269Execute tests: true

270sbt project found:

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

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

273Scala version: 3.8.0-RC6

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.0-RC6

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.0-RC6"

295"++3.8.0-RC6 -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.0-RC6 """{"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"

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.0-RC6

311OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in core/crossScalaVersions

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

313OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in vulcan/crossScalaVersions

314OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in fs2-kafka/crossScalaVersions

315OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in vulcan-testkit-munit/crossScalaVersions

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

317[info] Setting Scala version to 3.8.0-RC6 on 4 projects.

318[info] Switching Scala version on:

319[info] * fs2-kafka (2.12.20, 2.13.17, 3.8.0-RC6)

320[info] vulcan-testkit-munit (2.12.20, 2.13.17, 3.8.0-RC6)

321[info] core (2.12.20, 2.13.17, 3.8.0-RC6)

322[info] vulcan (2.12.20, 2.13.17, 3.8.0-RC6)

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:

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 8, 2026, 3:00:56 AM

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.0-RC6/classes ...

375[info] done compiling

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

377[info] done compiling

378[info] compiling 6 Scala sources to /build/repo/modules/vulcan/target/scala-3.8.0-RC6/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 (4 milliseconds)

385[info] avroSerializer/avroDeserializer

38603:01:27.342 [io-compute-0] 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

45503:01:27.342 [io-compute-2] 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

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

52303:01:27.452 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

524 auto.register.schemas = true

525 avro.reflection.allow.null = false

526 avro.remove.java.properties = false

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

528 basic.auth.credentials.source = URL

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

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

531 bearer.auth.client.id = null

532 bearer.auth.client.secret = null

533 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

537 bearer.auth.logical.cluster = null

538 bearer.auth.scope = null

539 bearer.auth.scope.claim.name = scope

540 bearer.auth.sub.claim.name = sub

541 bearer.auth.token = [hidden]

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

543 http.connect.timeout.ms = 60000

544 http.read.timeout.ms = 60000

545 id.compatibility.strict = true

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

547 latest.cache.size = 1000

548 latest.cache.ttl.sec = -1

549 latest.compatibility.strict = true

550 max.retries = 3

551 max.schemas.per.subject = 1000

552 normalize.schemas = false

553 propagate.schema.tags = false

554 proxy.host =

555 proxy.port = -1

556 retries.max.wait.ms = 20000

557 retries.wait.ms = 1000

558 rule.actions = []

559 rule.executors = []

560 rule.service.loader.enable = true

561 schema.format = null

562 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

576 schema.registry.ssl.provider = null

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

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

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

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

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

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

583 schema.registry.url = []

584 schema.registry.url.randomize = false

585 use.latest.version = false

586 use.latest.with.metadata = null

587 use.schema.id = -1

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

59003:01:27.453 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

591 auto.register.schemas = true

592 avro.reflection.allow.null = false

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

594 basic.auth.credentials.source = URL

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

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

597 bearer.auth.client.id = null

598 bearer.auth.client.secret = null

599 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

603 bearer.auth.logical.cluster = null

604 bearer.auth.scope = null

605 bearer.auth.scope.claim.name = scope

606 bearer.auth.sub.claim.name = sub

607 bearer.auth.token = [hidden]

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

609 http.connect.timeout.ms = 60000

610 http.read.timeout.ms = 60000

611 id.compatibility.strict = true

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

613 latest.cache.size = 1000

614 latest.cache.ttl.sec = -1

615 latest.compatibility.strict = true

616 max.retries = 3

617 max.schemas.per.subject = 1000

618 normalize.schemas = false

619 propagate.schema.tags = false

620 proxy.host =

621 proxy.port = -1

622 retries.max.wait.ms = 20000

623 retries.wait.ms = 1000

624 rule.actions = []

625 rule.executors = []

626 rule.service.loader.enable = true

627 schema.format = null

628 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

642 schema.registry.ssl.provider = null

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

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

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

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

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

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

649 schema.registry.url = []

650 schema.registry.url.randomize = false

651 specific.avro.key.type = null

652 specific.avro.reader = false

653 specific.avro.value.type = null

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

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

66003:01:27.465 [io-compute-0] 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

72703:01:27.466 [io-compute-2] 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

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

797[info] AvroSettingsSpec:

798[info] AvroSettings

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

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

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

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

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

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

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

806[info] - should provide withCreateAvroSerializer (1 millisecond)

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

808[info] - should provide toString (0 milliseconds)

809[info] AvroSerializerSpec:

810[info] AvroSerializer

81103:01:27.736 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

812 auto.register.schemas = true

813 avro.reflection.allow.null = false

814 avro.remove.java.properties = false

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

816 basic.auth.credentials.source = URL

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

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

819 bearer.auth.client.id = null

820 bearer.auth.client.secret = null

821 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

825 bearer.auth.logical.cluster = null

826 bearer.auth.scope = null

827 bearer.auth.scope.claim.name = scope

828 bearer.auth.sub.claim.name = sub

829 bearer.auth.token = [hidden]

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

831 http.connect.timeout.ms = 60000

832 http.read.timeout.ms = 60000

833 id.compatibility.strict = true

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

835 latest.cache.size = 1000

836 latest.cache.ttl.sec = -1

837 latest.compatibility.strict = true

838 max.retries = 3

839 max.schemas.per.subject = 1000

840 normalize.schemas = false

841 propagate.schema.tags = false

842 proxy.host =

843 proxy.port = -1

844 retries.max.wait.ms = 20000

845 retries.wait.ms = 1000

846 rule.actions = []

847 rule.executors = []

848 rule.service.loader.enable = true

849 schema.format = null

850 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

864 schema.registry.ssl.provider = null

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

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

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

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

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

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

871 schema.registry.url = []

872 schema.registry.url.randomize = false

873 use.latest.version = false

874 use.latest.with.metadata = null

875 use.schema.id = -1

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

87803:01:27.744 [io-compute-2] 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

945[info] - can create a serializer (15 milliseconds)

94603:01:27.754 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

947 auto.register.schemas = true

948 avro.reflection.allow.null = false

949 avro.remove.java.properties = false

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

951 basic.auth.credentials.source = URL

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

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

954 bearer.auth.client.id = null

955 bearer.auth.client.secret = null

956 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

960 bearer.auth.logical.cluster = null

961 bearer.auth.scope = null

962 bearer.auth.scope.claim.name = scope

963 bearer.auth.sub.claim.name = sub

964 bearer.auth.token = [hidden]

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

966 http.connect.timeout.ms = 60000

967 http.read.timeout.ms = 60000

968 id.compatibility.strict = true

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

970 latest.cache.size = 1000

971 latest.cache.ttl.sec = -1

972 latest.compatibility.strict = true

973 max.retries = 3

974 max.schemas.per.subject = 1000

975 normalize.schemas = false

976 propagate.schema.tags = false

977 proxy.host =

978 proxy.port = -1

979 retries.max.wait.ms = 20000

980 retries.wait.ms = 1000

981 rule.actions = []

982 rule.executors = []

983 rule.service.loader.enable = true

984 schema.format = null

985 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

999 schema.registry.ssl.provider = null

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

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

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

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

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

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

1006 schema.registry.url = []

1007 schema.registry.url.randomize = false

1008 use.latest.version = false

1009 use.latest.with.metadata = null

1010 use.schema.id = -1

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

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

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

1015[info] - toString (5 milliseconds)

1016[info] AuthSpec:

1017[info] Auth.Basic

1018[info] - should include the username in toString (4 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 (3 milliseconds)

1022[info] Auth.None

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

1024[info] SchemaRegistryClientSettingsSpec:

1025[info] SchemaRegistryClientSettings

1026[info] - should provide withMaxCacheSize (1 millisecond)

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

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

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

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

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

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

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

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

1035[info] - should provide Show (1 millisecond)

103603:01:27.866 [io-compute-1] 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

1105[info] AvroDeserializerSpec:

1106[info] AvroDeserializer

110703:01:27.871 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

1108 auto.register.schemas = true

1109 avro.reflection.allow.null = false

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

1111 basic.auth.credentials.source = URL

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

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

1114 bearer.auth.client.id = null

1115 bearer.auth.client.secret = null

1116 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

1120 bearer.auth.logical.cluster = null

1121 bearer.auth.scope = null

1122 bearer.auth.scope.claim.name = scope

1123 bearer.auth.sub.claim.name = sub

1124 bearer.auth.token = [hidden]

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

1126 http.connect.timeout.ms = 60000

1127 http.read.timeout.ms = 60000

1128 id.compatibility.strict = true

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

1130 latest.cache.size = 1000

1131 latest.cache.ttl.sec = -1

1132 latest.compatibility.strict = true

1133 max.retries = 3

1134 max.schemas.per.subject = 1000

1135 normalize.schemas = false

1136 propagate.schema.tags = false

1137 proxy.host =

1138 proxy.port = -1

1139 retries.max.wait.ms = 20000

1140 retries.wait.ms = 1000

1141 rule.actions = []

1142 rule.executors = []

1143 rule.service.loader.enable = true

1144 schema.format = null

1145 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

1159 schema.registry.ssl.provider = null

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

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

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

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

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

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

1166 schema.registry.url = []

1167 schema.registry.url.randomize = false

1168 specific.avro.key.type = null

1169 specific.avro.reader = false

1170 specific.avro.value.type = null

1171 use.latest.version = false

1172 use.latest.with.metadata = null

1173 use.schema.id = -1

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

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

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

117803:01:27.880 [io-compute-1] 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

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.0-RC6/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.0-RC6/test-classes ...

1256[info] done compiling

1257[info] TimestampLawsSpec:

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

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

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

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

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

1265[info] IsolationLevelSpec:

1266[info] IsolationLevel

1267[info] - should have toString matching name (1 millisecond)

1268[info] JitterSpec:

1269[info] Jitter#default

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

1271[info] Jitter#none

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

1275[info] - should have expected message and toString (1 millisecond)

1276[info] ConsumerRecordLawsSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1316[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (11 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 (7 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1340[info] TimestampSpec:

1341[info] Timeout#createTime

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

1343[info] - should not have a logAppendTime (0 milliseconds)

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

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

1346[info] Timeout#logAppendTime

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

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

1349[info] - should not have an unknownTime (0 milliseconds)

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

1351[info] Timeout#unknownTime

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

1353[info] - should not have a createTime (2 milliseconds)

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 (0 milliseconds)

1359[info] - should not have unknownTime (0 milliseconds)

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

1361[info] - should not include any time in toString (0 milliseconds)

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 (165 milliseconds)

1368[info] ProducerRecordLawsSpec:

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

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

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

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

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

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

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

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

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

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

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

1380[info] - ProducerRecord.traverseLaws.traverse.dropWhile_ reference (3 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 (4 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

1396[info] - ProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (3 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 (4 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1429[info] AutoOffsetResetSpec:

1430[info] AutoOffsetReset

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

1432[info] ConsumerSettingsSpec:

1433[info] ConsumerSettings

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

1435[info] - should provide withBootstrapServers (0 milliseconds)

1436[info] - should provide withAutoOffsetReset (1 millisecond)

1437[info] - should provide withAllowAutoCreateTopics (0 milliseconds)

1438[info] - should provide withClientRack (0 milliseconds)

1439[info] - should provide withClientId (0 milliseconds)

1440[info] - should provide withGroupId (0 milliseconds)

1441[info] - should provide withGroupInstanceId (1 millisecond)

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

1443[info] - should provide withMaxPollInterval (1 millisecond)

1444[info] - should provide withSessionTimeout (1 millisecond)

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 (1 millisecond)

1451[info] - should provide withProperty (0 milliseconds)

1452[info] - should provide withProperties (0 milliseconds)

1453[info] - should provide withCloseTimeout (1 millisecond)

1454[info] - should provide withCommitTimeout (0 milliseconds)

1455[info] - should provide withPollInterval (0 milliseconds)

1456[info] - should provide withPollTimeout (0 milliseconds)

1457[info] - should provide withCommitRecovery (0 milliseconds)

1458[info] - should provide withRecordMetadata (1 millisecond)

1459[info] - should provide withMaxPrefetchBatches (0 milliseconds)

1460[info] - should be able to create with and without deserializer creation effects (0 milliseconds)

1461[info] - should be able to implicitly create with and without deserializer creation effects (3 milliseconds)

1462[info] - should have a Show instance and matching toString (5 milliseconds)

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

1466[info] HeaderSerializerSpec:

1467[info] - HeaderSerializer.contravariant.contravariant composition (84 milliseconds)

1468[info] - HeaderSerializer.contravariant.contravariant identity (40 milliseconds)

1469[info] - HeaderSerializer.contravariant.invariant composition (49 milliseconds)

1470[info] - HeaderSerializer.contravariant.invariant identity (41 milliseconds)

1471[info] - HeaderSerializer#mapBytes (6 milliseconds)

1472[info] - HeaderSerializer#const (2 milliseconds)

1473[info] - HeaderSerializer#asNull (1 millisecond)

1474[info] - HeaderSerializer#empty (2 milliseconds)

1475[info] - HeaderSerializer#option (2 milliseconds)

1476[info] - HeaderSerializer#unit (0 milliseconds)

1477[info] - HeaderSerializer#toString (0 milliseconds)

1478[info] - HeaderSerializer#string (8 milliseconds)

1479[info] - HeaderSerializer#uuid (5 milliseconds)

1480[info] - HeaderSerializer#double (2 milliseconds)

1481[info] - HeaderSerializer#float (3 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 (3 milliseconds)

1487[info] - Headers.eqLaws.eq.reflexivity eq (2 milliseconds)

1488[info] - Headers.eqLaws.eq.symmetry eq (2 milliseconds)

1489[info] - Headers.eqLaws.eq.transitivity eq (2 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 (7 milliseconds)

1496[info] - should override using the provided offset (19 milliseconds)

1497[info] - should be able to update with batch (12 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 (0 milliseconds)

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 (0 milliseconds)

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 (2 milliseconds)

1514[info] - should provide withCloseTimeout (0 milliseconds)

1515[info] - should have a Show instance and matching toString (2 milliseconds)

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 (5 milliseconds)

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

1519[info] - should provide failFastProduce default value (1 millisecond)

1520[info] - should be able to set failFastProduce (0 milliseconds)

1521[info] ConsumerRecordSpec:

1522[info] ConsumerRecord#fromJava

1523[info] - should convert timestamps (9 milliseconds)

1524[info] - should convert serialized key size (1 millisecond)

1525[info] - should convert serialized value size (1 millisecond)

1526[info] - should convert leader epoch (1 millisecond)

1527[info] ConsumerRecord#toString

1528[info] - should include headers when present (0 milliseconds)

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 (0 milliseconds)

1532[info] - should include leader epoch if present (1 millisecond)

1533[info] AcksSpec:

1534[info] Acks

1535[info] - should have toString matching name (0 milliseconds)

1536[info] CommitRecoverySpec:

1537[info] CommitRecovery#Default

1541[info] - should have Default as String representation (0 milliseconds)

1542[info] CommitRecovery#None

1544[info] - should have None as String representation (0 milliseconds)

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 (1 millisecond)

1549[info] - CommittableOffset.eqLaws.eq.transitivity eq (1 millisecond)

1550[info] CommittableProducerRecordsLawsSpec:

1551[info] - CommittableProducerRecord.eqLaws.eq.antisymmetry eq (6 milliseconds)

1552[info] - CommittableProducerRecord.eqLaws.eq.reflexivity eq (3 milliseconds)

1553[info] - CommittableProducerRecord.eqLaws.eq.symmetry eq (4 milliseconds)

1554[info] - CommittableProducerRecord.eqLaws.eq.transitivity eq (6 milliseconds)

1555[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirst reference (6 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 (6 milliseconds)

1559[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with forall (13 milliseconds)

1560[info] - CommittableProducerRecord.traverseLaws.traverse.covariant composition (7 milliseconds)

1561[info] - CommittableProducerRecord.traverseLaws.traverse.covariant identity (4 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 (3 milliseconds)

1565[info] - CommittableProducerRecord.traverseLaws.traverse.filter_ reference (5 milliseconds)

1566[info] - CommittableProducerRecord.traverseLaws.traverse.fold reference (3 milliseconds)

1567[info] - CommittableProducerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (10 milliseconds)

1568[info] - CommittableProducerRecord.traverseLaws.traverse.foldM identity (6 milliseconds)

1569[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (6 milliseconds)

1570[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight is lazy (4 milliseconds)

1571[info] - CommittableProducerRecord.traverseLaws.traverse.foldRightDefer consistency (9 milliseconds)

1572[info] - CommittableProducerRecord.traverseLaws.traverse.forall consistent with exists (2 milliseconds)

1573[info] - CommittableProducerRecord.traverseLaws.traverse.forall is lazy (2 milliseconds)

1574[info] - CommittableProducerRecord.traverseLaws.traverse.forall true if empty (3 milliseconds)

1575[info] - CommittableProducerRecord.traverseLaws.traverse.get reference (4 milliseconds)

1576[info] - CommittableProducerRecord.traverseLaws.traverse.invariant composition (7 milliseconds)

1577[info] - CommittableProducerRecord.traverseLaws.traverse.invariant identity (5 milliseconds)

1578[info] - CommittableProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (6 milliseconds)

1579[info] - CommittableProducerRecord.traverseLaws.traverse.nonEmpty reference (3 milliseconds)

1580[info] - CommittableProducerRecord.traverseLaws.traverse.ordered consistency (4 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 (4 milliseconds)

1584[info] - CommittableProducerRecord.traverseLaws.traverse.toList reference (7 milliseconds)

1585[info] - CommittableProducerRecord.traverseLaws.traverse.traverse derive foldMap (7 milliseconds)

1586[info] - CommittableProducerRecord.traverseLaws.traverse.traverse identity (5 milliseconds)

1587[info] - CommittableProducerRecord.traverseLaws.traverse.traverse order consistency (5 milliseconds)

1588[info] - CommittableProducerRecord.traverseLaws.traverse.traverse parallel composition (6 milliseconds)

1589[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (9 milliseconds)

1590[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (7 milliseconds)

1591[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (7 milliseconds)

1592[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (5 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 (6 milliseconds)

1596[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (4 milliseconds)

1597[info] - CommittableProducerRecord.traverseLaws.traverse.traverse sequential composition (5 milliseconds)

1598[info] - CommittableProducerRecord.traverseLaws.traverse.traverse traverseTap (5 milliseconds)

1599[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (4 milliseconds)

1600[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (6 milliseconds)

1601[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse sequential composition (5 milliseconds)

1602[info] - CommittableProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (2 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 (4 milliseconds)

1606[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (4 milliseconds)

1607[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (4 milliseconds)

1608[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (3 milliseconds)

1609[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (4 milliseconds)

1610[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (8 milliseconds)

1611[info] HeaderDeserializerSpec:

1612[info] - HeaderDeserializer.monad.ap consistent with product + map (50 milliseconds)

1613[info] - HeaderDeserializer.monad.applicative homomorphism (28 milliseconds)

1614[info] - HeaderDeserializer.monad.applicative identity (35 milliseconds)

1615[info] - HeaderDeserializer.monad.applicative interchange (29 milliseconds)

1616[info] - HeaderDeserializer.monad.applicative map (35 milliseconds)

1617[info] - HeaderDeserializer.monad.applicative unit (26 milliseconds)

1618[info] - HeaderDeserializer.monad.apply composition (33 milliseconds)

1619[info] - HeaderDeserializer.monad.covariant composition (38 milliseconds)

1620[info] - HeaderDeserializer.monad.covariant identity (28 milliseconds)

1621[info] - HeaderDeserializer.monad.flatMap associativity (35 milliseconds)

1622[info] - HeaderDeserializer.monad.flatMap consistent apply (41 milliseconds)

1623[info] - HeaderDeserializer.monad.flatMap from tailRecM consistency (47 milliseconds)

1624[info] - HeaderDeserializer.monad.invariant composition (29 milliseconds)

1625[info] - HeaderDeserializer.monad.invariant identity (23 milliseconds)

1626[info] - HeaderDeserializer.monad.map flatMap coherence (30 milliseconds)

1627[info] - HeaderDeserializer.monad.map2/map2Eval consistency (27 milliseconds)

1628[info] - HeaderDeserializer.monad.map2/product-map consistency (21 milliseconds)

1629[info] - HeaderDeserializer.monad.mapOrKeepToMapEquivalence (30 milliseconds)

1630[info] - HeaderDeserializer.monad.monad left identity (24 milliseconds)

1631[info] - HeaderDeserializer.monad.monad right identity (14 milliseconds)

1632[info] - HeaderDeserializer.monad.monoidal left identity (15 milliseconds)

1633[info] - HeaderDeserializer.monad.monoidal right identity (22 milliseconds)

1634[info] - HeaderDeserializer.monad.mproduct consistent flatMap (45 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 (32 milliseconds)

1638[info] - HeaderDeserializer.monad.semigroupal associativity (42 milliseconds)

1639[info] - HeaderDeserializer.monad.tailRecM consistent flatMap (28 milliseconds)

1640[info] - HeaderDeserializer.monad.tailRecM stack safety (48 milliseconds)

1641[info] - HeaderDeserializer#delay (4 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 (4 milliseconds)

1647[info] - CommittableConsumerRecord.eqLaws.eq.reflexivity eq (5 milliseconds)

1648[info] - CommittableConsumerRecord.eqLaws.eq.symmetry eq (4 milliseconds)

1649[info] - CommittableConsumerRecord.eqLaws.eq.transitivity eq (3 milliseconds)

1650[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirst reference (3 milliseconds)

1651[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirstSome reference (3 milliseconds)

1652[info] - CommittableConsumerRecord.traverseLaws.traverse.contains all elements from itself (4 milliseconds)

1653[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with exists (4 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 (2 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 (2 milliseconds)

1663[info] - CommittableConsumerRecord.traverseLaws.traverse.foldM identity (2 milliseconds)

1664[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (2 milliseconds)

1665[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight is lazy (2 milliseconds)

1666[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (5 milliseconds)

1667[info] - CommittableConsumerRecord.traverseLaws.traverse.forall consistent with exists (3 milliseconds)

1668[info] - CommittableConsumerRecord.traverseLaws.traverse.forall is lazy (1 millisecond)

1669[info] - CommittableConsumerRecord.traverseLaws.traverse.forall true if empty (2 milliseconds)

1670[info] - CommittableConsumerRecord.traverseLaws.traverse.get reference (2 milliseconds)

1671[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant composition (5 milliseconds)

1672[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant identity (2 milliseconds)

1673[info] - CommittableConsumerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (2 milliseconds)

1674[info] - CommittableConsumerRecord.traverseLaws.traverse.nonEmpty reference (3 milliseconds)

1675[info] - CommittableConsumerRecord.traverseLaws.traverse.ordered consistency (2 milliseconds)

1676[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (3 milliseconds)

1677[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (3 milliseconds)

1678[info] - CommittableConsumerRecord.traverseLaws.traverse.takeWhile_ reference (3 milliseconds)

1679[info] - CommittableConsumerRecord.traverseLaws.traverse.toList reference (3 milliseconds)

1680[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse derive foldMap (3 milliseconds)

1681[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

1682[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse order consistency (4 milliseconds)

1683[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse parallel composition (2 milliseconds)

1684[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (5 milliseconds)

1685[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (4 milliseconds)

1686[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (3 milliseconds)

1687[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (4 milliseconds)

1688[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (4 milliseconds)

1689[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref updated (6 milliseconds)

1690[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (3 milliseconds)

1691[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (4 milliseconds)

1692[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse sequential composition (2 milliseconds)

1693[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse traverseTap (3 milliseconds)

1694[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (2 milliseconds)

1695[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (2 milliseconds)

1696[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (2 milliseconds)

1697[info] - CommittableConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (2 milliseconds)

1698[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (2 milliseconds)

1699[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (3 milliseconds)

1700[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (2 milliseconds)

1701[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (2 milliseconds)

1702[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (1 millisecond)

1703[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (4 milliseconds)

1704[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (3 milliseconds)

1705[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (2 milliseconds)

1708[info] - should have expected message and toString (1 millisecond)

1709[info] HeaderSpec:

1710[info] Header

1711[info] - toString should be Header(key -> value) (1 millisecond)

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 (0 milliseconds)

1716[info] - should deserialize with attemptAs (2 milliseconds)

1717[info] HeaderLawsSpec:

1718[info] - Header.eqLaws.eq.antisymmetry eq (3 milliseconds)

1719[info] - Header.eqLaws.eq.reflexivity eq (3 milliseconds)

1720[info] - Header.eqLaws.eq.symmetry eq (2 milliseconds)

1721[info] - Header.eqLaws.eq.transitivity eq (2 milliseconds)

1722[info] SerializerSpec:

1723[info] - Serializer[IO, *].contravariant.contravariant composition (212 milliseconds)

1724[info] - Serializer[IO, *].contravariant.contravariant identity (285 milliseconds)

1725[info] - Serializer[IO, *].contravariant.invariant composition (198 milliseconds)

1726[info] - Serializer[IO, *].contravariant.invariant identity (90 milliseconds)

1727[info] - Serializer#mapBytes (7 milliseconds)

1728[info] - Serializer#apply (5 milliseconds)

1729[info] - Serializer#identity (5 milliseconds)

1730[info] - Serializer#const (3 milliseconds)

1731[info] - Serializer#defer (9 milliseconds)

1732[info] - Serializer#fail (9 milliseconds)

1733[info] - Serializer#failWith (12 milliseconds)

1734[info] - Serializer#suspend (11 milliseconds)

1735[info] - Serializer#headers (14 milliseconds)

1736[info] - Serializer#topic (14 milliseconds)

1737[info] - Serializer#topic.unknown (8 milliseconds)

1738[info] - Serializer#asNull (3 milliseconds)

1739[info] - Serializer#empty (2 milliseconds)

1740[info] - Serializer#option (4 milliseconds)

1741[info] - Serializer#unit (0 milliseconds)

1742[info] - Serializer#toString (0 milliseconds)

1743[info] - Serializer#string (3 milliseconds)

1744[info] - Serializer#uuid (8 milliseconds)

1745[info] - Serializer#uuid.default (8 milliseconds)

1746[info] - Serializer#double (7 milliseconds)

1747[info] - Serializer#float (6 milliseconds)

1748[info] - Serializer#int (5 milliseconds)

1749[info] - Serializer#long (10 milliseconds)

1750[info] - Serializer#short (4 milliseconds)

1751[info] DeserializerSpec:

1752[info] - Deserializer[IO, *].monadError.ap consistent with product + map (219 milliseconds)

1753[info] - Deserializer[IO, *].monadError.applicative homomorphism (94 milliseconds)

1754[info] - Deserializer[IO, *].monadError.applicative identity (102 milliseconds)

1755[info] - Deserializer[IO, *].monadError.applicative interchange (82 milliseconds)

1756[info] - Deserializer[IO, *].monadError.applicative map (84 milliseconds)

1757[info] - Deserializer[IO, *].monadError.applicative unit (73 milliseconds)

1758[info] - Deserializer[IO, *].monadError.applicativeError adaptError pure (103 milliseconds)

1759[info] - Deserializer[IO, *].monadError.applicativeError adaptError raise (114 milliseconds)

1760[info] - Deserializer[IO, *].monadError.applicativeError attempt consistent with attemptT (86 milliseconds)

1761[info] - Deserializer[IO, *].monadError.applicativeError attempt fromEither consistent with pure (83 milliseconds)

1762[info] - Deserializer[IO, *].monadError.applicativeError handle (109 milliseconds)

1763[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError left-distributes over ap (100 milliseconds)

1764[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError right-distributes over ap (103 milliseconds)

1765[info] - Deserializer[IO, *].monadError.applicativeError handleError consistent with recover (76 milliseconds)

1766[info] - Deserializer[IO, *].monadError.applicativeError handleError pure (61 milliseconds)

1767[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith consistent with recoverWith (63 milliseconds)

1768[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith pure (66 milliseconds)

1769[info] - Deserializer[IO, *].monadError.applicativeError handleWith (84 milliseconds)

1770[info] - Deserializer[IO, *].monadError.applicativeError onError pure (73 milliseconds)

1771[info] - Deserializer[IO, *].monadError.applicativeError onError raise (80 milliseconds)

1772[info] - Deserializer[IO, *].monadError.applicativeError pure attempt (74 milliseconds)

1773[info] - Deserializer[IO, *].monadError.applicativeError raiseError attempt (67 milliseconds)

1774[info] - Deserializer[IO, *].monadError.applicativeError recover consistent with recoverWith (73 milliseconds)

1775[info] - Deserializer[IO, *].monadError.applicativeError redeem is derived from attempt and map (80 milliseconds)

1776[info] - Deserializer[IO, *].monadError.applicativeError voidError consistent with void+handleError (62 milliseconds)

1777[info] - Deserializer[IO, *].monadError.apply composition (71 milliseconds)

1778[info] - Deserializer[IO, *].monadError.covariant composition (63 milliseconds)

1779[info] - Deserializer[IO, *].monadError.covariant identity (63 milliseconds)

1780[info] - Deserializer[IO, *].monadError.flatMap associativity (76 milliseconds)

1781[info] - Deserializer[IO, *].monadError.flatMap consistent apply (75 milliseconds)

1782[info] - Deserializer[IO, *].monadError.flatMap from tailRecM consistency (75 milliseconds)

1783[info] - Deserializer[IO, *].monadError.invariant composition (68 milliseconds)

1784[info] - Deserializer[IO, *].monadError.invariant identity (67 milliseconds)

1785[info] - Deserializer[IO, *].monadError.map flatMap coherence (65 milliseconds)

1786[info] - Deserializer[IO, *].monadError.map2/map2Eval consistency (66 milliseconds)

1787[info] - Deserializer[IO, *].monadError.map2/product-map consistency (74 milliseconds)

1788[info] - Deserializer[IO, *].monadError.mapOrKeepToMapEquivalence (68 milliseconds)

1789[info] - Deserializer[IO, *].monadError.monad left identity (67 milliseconds)

1790[info] - Deserializer[IO, *].monadError.monad right identity (61 milliseconds)

1791[info] - Deserializer[IO, *].monadError.monadError ensure consistency (71 milliseconds)

1792[info] - Deserializer[IO, *].monadError.monadError ensureOr consistency (70 milliseconds)

1793[info] - Deserializer[IO, *].monadError.monadError left zero (73 milliseconds)

1794[info] - Deserializer[IO, *].monadError.monadError redeemWith is derived from attempt and flatMap (67 milliseconds)

1795[info] - Deserializer[IO, *].monadError.monadError rethrow attempt (62 milliseconds)

1796[info] - Deserializer[IO, *].monadError.monoidal left identity (68 milliseconds)

1797[info] - Deserializer[IO, *].monadError.monoidal right identity (62 milliseconds)

1798[info] - Deserializer[IO, *].monadError.mproduct consistent flatMap (144 milliseconds)

1799[info] - Deserializer[IO, *].monadError.productL consistent map2 (64 milliseconds)

1800[info] - Deserializer[IO, *].monadError.productR consistent map2 (58 milliseconds)

1801[info] - Deserializer[IO, *].monadError.replicateA_ consistent with replicateA.void (65 milliseconds)

1802[info] - Deserializer[IO, *].monadError.semigroupal associativity (72 milliseconds)

1803[info] - Deserializer[IO, *].monadError.tailRecM consistent flatMap (101 milliseconds)

1804[info] - Deserializer[IO, *].monadError.tailRecM stack safety (219 milliseconds)

1805[info] - Deserializer#attempt (9 milliseconds)

1806[info] - Deserializer#fail (4 milliseconds)

1807[info] - Deserializer#failWith (5 milliseconds)

1808[info] - Deserializer#headers (18 milliseconds)

1809[info] - Deserializer#apply (4 milliseconds)

1810[info] - Deserializer#identity (4 milliseconds)

1811[info] - Deserializer#suspend (5 milliseconds)

1812[info] - Deserializer#topic (19 milliseconds)

1813[info] - Deserializer#topic.unknown (5 milliseconds)

1814[info] - Deserializer#attempt (implicit) (4 milliseconds)

1815[info] - Deserializer#option (4 milliseconds)

1816[info] - Deserializer#unit (2 milliseconds)

1817[info] - Deserializer#toString (1 millisecond)

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() (1 millisecond)

1825[info] - should return true for isEmpty (0 milliseconds)

1826[info] - should return false for nonEmpty (0 milliseconds)

1827[info] - should return false for exists (1 millisecond)

1828[info] - should not find any key (0 milliseconds)

1829[info] - should concat empty (2 milliseconds)

1830[info] - should concat non-empty (0 milliseconds)

1831[info] - should return empty Chain from toChain (1 millisecond)

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

1838[info] - lastHeader returns null (0 milliseconds)

1839[info] - headers returns empty iterable (1 millisecond)

1840[info] - toArray returns empty array (0 milliseconds)

1842[info] - iterator.hasNext returns false (1 millisecond)

1843[info] Headers#nonEmpty.asJava

1847[info] - lastHeader returns last header (1 millisecond)

1848[info] - lastHeaders returns existing header (0 milliseconds)

1849[info] - lastHeader returns null for missing key (0 milliseconds)

1850[info] - headers returns matching headers (4 milliseconds)

1851[info] - headers returns empty if no matching headers (0 milliseconds)

1852[info] - toArray returns elements (1 millisecond)

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 (0 milliseconds)

1859[info] - should return true for existing key (3 milliseconds)

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) (0 milliseconds)

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 (0 milliseconds)

1872[info] Headers#fromSeq

1873[info] - returns empty for empty seq (0 milliseconds)

1874[info] - returns non-empty for non-empty seq (0 milliseconds)

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 (6 milliseconds)

1881[info] KafkaHeaders#asScala

1882[info] - should convert empty (1 millisecond)

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.0-RC6

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.0-RC6"

1903"++3.8.0-RC6 -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.0-RC6 """{"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"

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.0-RC6

1919OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in core/crossScalaVersions

1920OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in vulcan/crossScalaVersions

1921OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in vulcan-testkit-munit/crossScalaVersions

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

1923OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in fs2-kafka/crossScalaVersions

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

1925[info] Setting Scala version to 3.8.0-RC6 on 4 projects.

1926[info] Switching Scala version on:

1927[info] * fs2-kafka (2.12.20, 2.13.17, 3.8.0-RC6)

1928[info] vulcan-testkit-munit (2.12.20, 2.13.17, 3.8.0-RC6)

1929[info] core (2.12.20, 2.13.17, 3.8.0-RC6)

1930[info] vulcan (2.12.20, 2.13.17, 3.8.0-RC6)

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:

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 8, 2026, 4:50:51 AM

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 (351 milliseconds)

1980[info] avroDeserializer

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

1982[info] avroSerializer/avroDeserializer

198304:50:57.535 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

1984 auto.register.schemas = true

1985 avro.reflection.allow.null = false

1986 avro.remove.java.properties = false

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

1988 basic.auth.credentials.source = URL

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

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

1991 bearer.auth.client.id = null

1992 bearer.auth.client.secret = null

1993 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

1997 bearer.auth.logical.cluster = null

1998 bearer.auth.scope = null

1999 bearer.auth.scope.claim.name = scope

2000 bearer.auth.sub.claim.name = sub

2001 bearer.auth.token = [hidden]

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

2003 http.connect.timeout.ms = 60000

2004 http.read.timeout.ms = 60000

2005 id.compatibility.strict = true

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

2007 latest.cache.size = 1000

2008 latest.cache.ttl.sec = -1

2009 latest.compatibility.strict = true

2010 max.retries = 3

2011 max.schemas.per.subject = 1000

2012 normalize.schemas = false

2013 propagate.schema.tags = false

2014 proxy.host =

2015 proxy.port = -1

2016 retries.max.wait.ms = 20000

2017 retries.wait.ms = 1000

2018 rule.actions = []

2019 rule.executors = []

2020 rule.service.loader.enable = true

2021 schema.format = null

2022 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

2036 schema.registry.ssl.provider = null

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

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

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

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

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

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

2043 schema.registry.url = []

2044 schema.registry.url.randomize = false

2045 use.latest.version = false

2046 use.latest.with.metadata = null

2047 use.schema.id = -1

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

205004:50:57.537 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2051 auto.register.schemas = true

2052 avro.reflection.allow.null = false

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

2054 basic.auth.credentials.source = URL

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

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

2057 bearer.auth.client.id = null

2058 bearer.auth.client.secret = null

2059 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

2063 bearer.auth.logical.cluster = null

2064 bearer.auth.scope = null

2065 bearer.auth.scope.claim.name = scope

2066 bearer.auth.sub.claim.name = sub

2067 bearer.auth.token = [hidden]

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

2069 http.connect.timeout.ms = 60000

2070 http.read.timeout.ms = 60000

2071 id.compatibility.strict = true

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

2073 latest.cache.size = 1000

2074 latest.cache.ttl.sec = -1

2075 latest.compatibility.strict = true

2076 max.retries = 3

2077 max.schemas.per.subject = 1000

2078 normalize.schemas = false

2079 propagate.schema.tags = false

2080 proxy.host =

2081 proxy.port = -1

2082 retries.max.wait.ms = 20000

2083 retries.wait.ms = 1000

2084 rule.actions = []

2085 rule.executors = []

2086 rule.service.loader.enable = true

2087 schema.format = null

2088 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

2102 schema.registry.ssl.provider = null

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

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

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

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

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

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

2109 schema.registry.url = []

2110 schema.registry.url.randomize = false

2111 specific.avro.key.type = null

2112 specific.avro.reader = false

2113 specific.avro.value.type = null

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

2119[info] - should be able to do roundtrip serialization (365 milliseconds)

212004:50:57.624 [io-compute-3] 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

218904:50:57.624 [io-compute-2] 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

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

225704:50:57.635 [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

232404:50:57.636 [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

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

2394[info] AvroSettingsSpec:

2395[info] AvroSettings

2396[info] - should provide withAutoRegisterSchemas (96 milliseconds)

2397[info] - should provide withKeySubjectNameStrategy (9 milliseconds)

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

2399[info] - should provide withProperty (8 milliseconds)

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

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

2402[info] - should provide withCreateAvroDeserializer (1 millisecond)

2403[info] - should provide withCreateAvroSerializer (1 millisecond)

2404[info] - should provide withRegisterSchema (3 milliseconds)

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

240604:50:57.822 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2407 auto.register.schemas = true

2408 avro.reflection.allow.null = false

2409 avro.remove.java.properties = false

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

2411 basic.auth.credentials.source = URL

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

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

2414 bearer.auth.client.id = null

2415 bearer.auth.client.secret = null

2416 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

2420 bearer.auth.logical.cluster = null

2421 bearer.auth.scope = null

2422 bearer.auth.scope.claim.name = scope

2423 bearer.auth.sub.claim.name = sub

2424 bearer.auth.token = [hidden]

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

2426 http.connect.timeout.ms = 60000

2427 http.read.timeout.ms = 60000

2428 id.compatibility.strict = true

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

2430 latest.cache.size = 1000

2431 latest.cache.ttl.sec = -1

2432 latest.compatibility.strict = true

2433 max.retries = 3

2434 max.schemas.per.subject = 1000

2435 normalize.schemas = false

2436 propagate.schema.tags = false

2437 proxy.host =

2438 proxy.port = -1

2439 retries.max.wait.ms = 20000

2440 retries.wait.ms = 1000

2441 rule.actions = []

2442 rule.executors = []

2443 rule.service.loader.enable = true

2444 schema.format = null

2445 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

2459 schema.registry.ssl.provider = null

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

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

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

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

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

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

2466 schema.registry.url = []

2467 schema.registry.url.randomize = false

2468 use.latest.version = false

2469 use.latest.with.metadata = null

2470 use.schema.id = -1

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

2473[info] AvroSerializerSpec:

2474[info] AvroSerializer

247504:50:57.829 [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

2542[info] - can create a serializer (11 milliseconds)

254304:50:57.836 [io-compute-3] 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

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

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

2612[info] - toString (2 milliseconds)

2613[info] AuthSpec:

2614[info] Auth.Basic

2615[info] - should include the username in toString (7 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) (7 milliseconds)

2625[info] - should provide withAuth(Auth.Bearer) (2 milliseconds)

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

2627[info] - should provide withProperty (2 milliseconds)

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

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

2630[info] - should provide withCreateSchemaRegistryClient (1 millisecond)

2631[info] - should provide toString (5 milliseconds)

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

2633[info] AvroDeserializerSpec:

2634[info] AvroDeserializer

263504:50:57.961 [io-compute-3] 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

270404:50:57.965 [io-compute-1] 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

2773[info] - can create a deserializer (12 milliseconds)

2774[info] - raises schema errors (4 milliseconds)

277504:50:57.976 [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

2845[info] - toString (0 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 (66 milliseconds)

2852[info] - Timestamp.eqLaws.eq.reflexivity eq (5 milliseconds)

2853[info] - Timestamp.eqLaws.eq.symmetry eq (12 milliseconds)

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

2857[info] - should have expected message and toString (8 milliseconds)

2858[info] IsolationLevelSpec:

2859[info] IsolationLevel

2860[info] - should have toString matching name (1 millisecond)

2861[info] JitterSpec:

2862[info] Jitter#default

2863[info] - should always apply jitter on values (263 milliseconds)

2864[info] Jitter#none

2865[info] - should never apply jitter on values (4 milliseconds)

2868[info] - should have expected message and toString (1 millisecond)

2869[info] ConsumerRecordLawsSpec:

2870[info] - ConsumerRecord.eqLaws.eq.antisymmetry eq (85 milliseconds)

2871[info] - ConsumerRecord.eqLaws.eq.reflexivity eq (21 milliseconds)

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

2873[info] - ConsumerRecord.eqLaws.eq.transitivity eq (31 milliseconds)

2874[info] - ConsumerRecord.traverseLaws.traverse.collectFirst reference (30 milliseconds)

2875[info] - ConsumerRecord.traverseLaws.traverse.collectFirstSome reference (16 milliseconds)

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

2877[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with exists (8 milliseconds)

2878[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with forall (8 milliseconds)

2879[info] - ConsumerRecord.traverseLaws.traverse.covariant composition (9 milliseconds)

2880[info] - ConsumerRecord.traverseLaws.traverse.covariant identity (12 milliseconds)

2881[info] - ConsumerRecord.traverseLaws.traverse.dropWhile_ reference (8 milliseconds)

2882[info] - ConsumerRecord.traverseLaws.traverse.exists consistent with find (9 milliseconds)

2883[info] - ConsumerRecord.traverseLaws.traverse.exists is lazy (10 milliseconds)

2884[info] - ConsumerRecord.traverseLaws.traverse.filter_ reference (8 milliseconds)

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

2886[info] - ConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (10 milliseconds)

2887[info] - ConsumerRecord.traverseLaws.traverse.foldM identity (18 milliseconds)

2888[info] - ConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (7 milliseconds)

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

2890[info] - ConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (10 milliseconds)

2891[info] - ConsumerRecord.traverseLaws.traverse.forall consistent with exists (8 milliseconds)

2892[info] - ConsumerRecord.traverseLaws.traverse.forall is lazy (3 milliseconds)

2893[info] - ConsumerRecord.traverseLaws.traverse.forall true if empty (5 milliseconds)

2894[info] - ConsumerRecord.traverseLaws.traverse.get reference (9 milliseconds)

2895[info] - ConsumerRecord.traverseLaws.traverse.invariant composition (13 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 (5 milliseconds)

2900[info] - ConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (5 milliseconds)

2901[info] - ConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (6 milliseconds)

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

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

2904[info] - ConsumerRecord.traverseLaws.traverse.traverse derive foldMap (13 milliseconds)

2905[info] - ConsumerRecord.traverseLaws.traverse.traverse identity (6 milliseconds)

2906[info] - ConsumerRecord.traverseLaws.traverse.traverse order consistency (5 milliseconds)

2907[info] - ConsumerRecord.traverseLaws.traverse.traverse parallel composition (7 milliseconds)

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

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

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

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

2912[info] - ConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (8 milliseconds)

2913[info] - ConsumerRecord.traverseLaws.traverse.traverse ref updated (7 milliseconds)

2914[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (5 milliseconds)

2915[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (6 milliseconds)

2916[info] - ConsumerRecord.traverseLaws.traverse.traverse sequential composition (16 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 (8 milliseconds)

2920[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (7 milliseconds)

2921[info] - ConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (2 milliseconds)

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

2923[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (5 milliseconds)

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

2925[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (5 milliseconds)

2926[info] - ConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (4 milliseconds)

2927[info] - ConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (5 milliseconds)

2928[info] - ConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (7 milliseconds)

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

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

2933[info] TimestampSpec:

2934[info] Timeout#createTime

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

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

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 (1 millisecond)

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 (0 milliseconds)

2946[info] - should not have a createTime (2 milliseconds)

2947[info] - should have an unknownTime (0 milliseconds)

2948[info] - should include the unknownTime in toString (2 milliseconds)

2949[info] Timestamp#none

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

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 (1 millisecond)

2955[info] CommittableConsumerRecordSpec:

2956[info] CommittableConsumerRecord

2957[info] - should have a Show instance and matching toString (3 milliseconds)

2958[info] KafkaSpec:

2959[info] commitBatchWithin

2960[info] - should batch commit according specified arguments (131 milliseconds)

2961[info] ProducerRecordLawsSpec:

2962[info] - ProducerRecord.eqLaws.eq.antisymmetry eq (7 milliseconds)

2963[info] - ProducerRecord.eqLaws.eq.reflexivity eq (4 milliseconds)

2964[info] - ProducerRecord.eqLaws.eq.symmetry eq (4 milliseconds)

2965[info] - ProducerRecord.eqLaws.eq.transitivity eq (13 milliseconds)

2966[info] - ProducerRecord.traverseLaws.traverse.collectFirst reference (7 milliseconds)

2967[info] - ProducerRecord.traverseLaws.traverse.collectFirstSome reference (5 milliseconds)

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

2969[info] - ProducerRecord.traverseLaws.traverse.contains consistent with exists (5 milliseconds)

2970[info] - ProducerRecord.traverseLaws.traverse.contains consistent with forall (5 milliseconds)

2971[info] - ProducerRecord.traverseLaws.traverse.covariant composition (7 milliseconds)

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

2973[info] - ProducerRecord.traverseLaws.traverse.dropWhile_ reference (3 milliseconds)

2974[info] - ProducerRecord.traverseLaws.traverse.exists consistent with find (4 milliseconds)

2975[info] - ProducerRecord.traverseLaws.traverse.exists is lazy (6 milliseconds)

2976[info] - ProducerRecord.traverseLaws.traverse.filter_ reference (6 milliseconds)

2977[info] - ProducerRecord.traverseLaws.traverse.fold reference (5 milliseconds)

2978[info] - ProducerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (6 milliseconds)

2979[info] - ProducerRecord.traverseLaws.traverse.foldM identity (10 milliseconds)

2980[info] - ProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (17 milliseconds)

2981[info] - ProducerRecord.traverseLaws.traverse.foldRight is lazy (5 milliseconds)

2982[info] - ProducerRecord.traverseLaws.traverse.foldRightDefer consistency (5 milliseconds)

2983[info] - ProducerRecord.traverseLaws.traverse.forall consistent with exists (4 milliseconds)

2984[info] - ProducerRecord.traverseLaws.traverse.forall is lazy (5 milliseconds)

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

2986[info] - ProducerRecord.traverseLaws.traverse.get reference (2 milliseconds)

2987[info] - ProducerRecord.traverseLaws.traverse.invariant composition (4 milliseconds)

2988[info] - ProducerRecord.traverseLaws.traverse.invariant identity (4 milliseconds)

2989[info] - ProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (2 milliseconds)

2990[info] - ProducerRecord.traverseLaws.traverse.nonEmpty reference (3 milliseconds)

2991[info] - ProducerRecord.traverseLaws.traverse.ordered consistency (4 milliseconds)

2992[info] - ProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (2 milliseconds)

2993[info] - ProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (3 milliseconds)

2994[info] - ProducerRecord.traverseLaws.traverse.takeWhile_ reference (2 milliseconds)

2995[info] - ProducerRecord.traverseLaws.traverse.toList reference (2 milliseconds)

2996[info] - ProducerRecord.traverseLaws.traverse.traverse derive foldMap (3 milliseconds)

2997[info] - ProducerRecord.traverseLaws.traverse.traverse identity (2 milliseconds)

2998[info] - ProducerRecord.traverseLaws.traverse.traverse order consistency (3 milliseconds)

2999[info] - ProducerRecord.traverseLaws.traverse.traverse parallel composition (1 millisecond)

3000[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (4 milliseconds)

3001[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (3 milliseconds)

3002[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (2 milliseconds)

3003[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (3 milliseconds)

3004[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (3 milliseconds)

3005[info] - ProducerRecord.traverseLaws.traverse.traverse ref updated (4 milliseconds)

3006[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (3 milliseconds)

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

3008[info] - ProducerRecord.traverseLaws.traverse.traverse sequential composition (4 milliseconds)

3009[info] - ProducerRecord.traverseLaws.traverse.traverse traverseTap (3 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 (2 milliseconds)

3013[info] - ProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (1 millisecond)

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

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

3016[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (1 millisecond)

3017[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (2 milliseconds)

3018[info] - ProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (2 milliseconds)

3019[info] - ProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (2 milliseconds)

3020[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (2 milliseconds)

3021[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (2 milliseconds)

3022[info] AutoOffsetResetSpec:

3023[info] AutoOffsetReset

3024[info] - should have toString matching name (1 millisecond)

3025[info] ConsumerSettingsSpec:

3026[info] ConsumerSettings

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

3028[info] - should provide withBootstrapServers (0 milliseconds)

3029[info] - should provide withAutoOffsetReset (1 millisecond)

3030[info] - should provide withAllowAutoCreateTopics (0 milliseconds)

3031[info] - should provide withClientRack (0 milliseconds)

3032[info] - should provide withClientId (2 milliseconds)

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

3034[info] - should provide withGroupInstanceId (1 millisecond)

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

3036[info] - should provide withMaxPollInterval (1 millisecond)

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 (0 milliseconds)

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

3042[info] - should provide withDefaultApiTimeout (1 millisecond)

3043[info] - should provide withIsolationLevel (1 millisecond)

3044[info] - should provide withProperty (1 millisecond)

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

3046[info] - should provide withCloseTimeout (0 milliseconds)

3047[info] - should provide withCommitTimeout (0 milliseconds)

3048[info] - should provide withPollInterval (0 milliseconds)

3049[info] - should provide withPollTimeout (1 millisecond)

3050[info] - should provide withCommitRecovery (0 milliseconds)

3051[info] - should provide withRecordMetadata (4 milliseconds)

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 (3 milliseconds)

3055[info] - should have a Show instance and matching toString (5 milliseconds)

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

3059[info] HeaderSerializerSpec:

3060[info] - HeaderSerializer.contravariant.contravariant composition (93 milliseconds)

3061[info] - HeaderSerializer.contravariant.contravariant identity (45 milliseconds)

3062[info] - HeaderSerializer.contravariant.invariant composition (55 milliseconds)

3063[info] - HeaderSerializer.contravariant.invariant identity (37 milliseconds)

3064[info] - HeaderSerializer#mapBytes (6 milliseconds)

3065[info] - HeaderSerializer#const (2 milliseconds)

3066[info] - HeaderSerializer#asNull (3 milliseconds)

3067[info] - HeaderSerializer#empty (3 milliseconds)

3068[info] - HeaderSerializer#option (3 milliseconds)

3069[info] - HeaderSerializer#unit (1 millisecond)

3070[info] - HeaderSerializer#toString (0 milliseconds)

3071[info] - HeaderSerializer#string (8 milliseconds)

3072[info] - HeaderSerializer#uuid (5 milliseconds)

3073[info] - HeaderSerializer#double (2 milliseconds)

3074[info] - HeaderSerializer#float (4 milliseconds)

3075[info] - HeaderSerializer#int (2 milliseconds)

3076[info] - HeaderSerializer#long (1 millisecond)

3077[info] - HeaderSerializer#short (2 milliseconds)

3078[info] HeadersLawsSpec:

3079[info] - Headers.eqLaws.eq.antisymmetry eq (3 milliseconds)

3080[info] - Headers.eqLaws.eq.reflexivity eq (2 milliseconds)

3081[info] - Headers.eqLaws.eq.symmetry eq (4 milliseconds)

3082[info] - Headers.eqLaws.eq.transitivity eq (4 milliseconds)

3083[info] CommittableOffsetBatchSpec:

3084[info] CommittableOffsetBatch#empty

3085[info] - should have no offsets (1 millisecond)

3086[info] - should return updated offset as batch (3 milliseconds)

3087[info] CommittableOffsetBatch#updated

3088[info] - should include the provided offset (8 milliseconds)

3089[info] - should override using the provided offset (16 milliseconds)

3090[info] - should be able to update with batch (10 milliseconds)

3091[info] CommittableOffsetBatch#toString

3092[info] - should provide a Show instance and matching toString (2 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 (1 millisecond)

3102[info] - should provide withEnableIdempotence (1 millisecond)

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 (1 millisecond)

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 (5 milliseconds)

3111[info] - should be able to set a custom blocking context (1 millisecond)

3112[info] - should provide failFastProduce default value (0 milliseconds)

3113[info] - should be able to set failFastProduce (0 milliseconds)

3114[info] ConsumerRecordSpec:

3115[info] ConsumerRecord#fromJava

3116[info] - should convert timestamps (11 milliseconds)

3117[info] - should convert serialized key size (5 milliseconds)

3118[info] - should convert serialized value size (3 milliseconds)

3119[info] - should convert leader epoch (1 millisecond)

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 (1 millisecond)

3126[info] AcksSpec:

3127[info] Acks

3128[info] - should have toString matching name (0 milliseconds)

3129[info] CommitRecoverySpec:

3130[info] CommitRecovery#Default

3134[info] - should have Default as String representation (0 milliseconds)

3135[info] CommitRecovery#None

3137[info] - should have None as String representation (0 milliseconds)

3138[info] CommittableOffsetLawsSpec:

3139[info] - CommittableOffset.eqLaws.eq.antisymmetry eq (2 milliseconds)

3140[info] - CommittableOffset.eqLaws.eq.reflexivity eq (2 milliseconds)

3141[info] - CommittableOffset.eqLaws.eq.symmetry eq (2 milliseconds)

3142[info] - CommittableOffset.eqLaws.eq.transitivity eq (3 milliseconds)

3143[info] CommittableProducerRecordsLawsSpec:

3144[info] - CommittableProducerRecord.eqLaws.eq.antisymmetry eq (6 milliseconds)

3145[info] - CommittableProducerRecord.eqLaws.eq.reflexivity eq (4 milliseconds)

3146[info] - CommittableProducerRecord.eqLaws.eq.symmetry eq (9 milliseconds)

3147[info] - CommittableProducerRecord.eqLaws.eq.transitivity eq (7 milliseconds)

3148[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirst reference (6 milliseconds)

3149[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirstSome reference (5 milliseconds)

3150[info] - CommittableProducerRecord.traverseLaws.traverse.contains all elements from itself (6 milliseconds)

3151[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with exists (4 milliseconds)

3152[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with forall (5 milliseconds)

3153[info] - CommittableProducerRecord.traverseLaws.traverse.covariant composition (8 milliseconds)

3154[info] - CommittableProducerRecord.traverseLaws.traverse.covariant identity (5 milliseconds)

3155[info] - CommittableProducerRecord.traverseLaws.traverse.dropWhile_ reference (3 milliseconds)

3156[info] - CommittableProducerRecord.traverseLaws.traverse.exists consistent with find (3 milliseconds)

3157[info] - CommittableProducerRecord.traverseLaws.traverse.exists is lazy (3 milliseconds)

3158[info] - CommittableProducerRecord.traverseLaws.traverse.filter_ reference (4 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 (7 milliseconds)

3162[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (6 milliseconds)

3163[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight is lazy (5 milliseconds)

3164[info] - CommittableProducerRecord.traverseLaws.traverse.foldRightDefer consistency (9 milliseconds)

3165[info] - CommittableProducerRecord.traverseLaws.traverse.forall consistent with exists (5 milliseconds)

3166[info] - CommittableProducerRecord.traverseLaws.traverse.forall is lazy (4 milliseconds)

3167[info] - CommittableProducerRecord.traverseLaws.traverse.forall true if empty (2 milliseconds)

3168[info] - CommittableProducerRecord.traverseLaws.traverse.get reference (7 milliseconds)

3169[info] - CommittableProducerRecord.traverseLaws.traverse.invariant composition (9 milliseconds)

3170[info] - CommittableProducerRecord.traverseLaws.traverse.invariant identity (6 milliseconds)

3171[info] - CommittableProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (7 milliseconds)

3172[info] - CommittableProducerRecord.traverseLaws.traverse.nonEmpty reference (10 milliseconds)

3173[info] - CommittableProducerRecord.traverseLaws.traverse.ordered consistency (4 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 (4 milliseconds)

3177[info] - CommittableProducerRecord.traverseLaws.traverse.toList reference (5 milliseconds)

3178[info] - CommittableProducerRecord.traverseLaws.traverse.traverse derive foldMap (7 milliseconds)

3179[info] - CommittableProducerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

3180[info] - CommittableProducerRecord.traverseLaws.traverse.traverse order consistency (3 milliseconds)

3181[info] - CommittableProducerRecord.traverseLaws.traverse.traverse parallel composition (7 milliseconds)

3182[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (11 milliseconds)

3183[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (6 milliseconds)

3184[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (6 milliseconds)

3185[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (6 milliseconds)

3186[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (4 milliseconds)

3187[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref updated (4 milliseconds)

3188[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (5 milliseconds)

3189[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (5 milliseconds)

3190[info] - CommittableProducerRecord.traverseLaws.traverse.traverse sequential composition (5 milliseconds)

3191[info] - CommittableProducerRecord.traverseLaws.traverse.traverse traverseTap (5 milliseconds)

3192[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (4 milliseconds)

3193[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (5 milliseconds)

3194[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse sequential composition (6 milliseconds)

3195[info] - CommittableProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (4 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 (8 milliseconds)

3199[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (4 milliseconds)

3200[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (5 milliseconds)

3201[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (5 milliseconds)

3202[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (6 milliseconds)

3203[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (4 milliseconds)

3204[info] HeaderDeserializerSpec:

3205[info] - HeaderDeserializer.monad.ap consistent with product + map (50 milliseconds)

3206[info] - HeaderDeserializer.monad.applicative homomorphism (34 milliseconds)

3207[info] - HeaderDeserializer.monad.applicative identity (35 milliseconds)

3208[info] - HeaderDeserializer.monad.applicative interchange (30 milliseconds)

3209[info] - HeaderDeserializer.monad.applicative map (41 milliseconds)

3210[info] - HeaderDeserializer.monad.applicative unit (24 milliseconds)

3211[info] - HeaderDeserializer.monad.apply composition (31 milliseconds)

3212[info] - HeaderDeserializer.monad.covariant composition (37 milliseconds)

3213[info] - HeaderDeserializer.monad.covariant identity (22 milliseconds)

3214[info] - HeaderDeserializer.monad.flatMap associativity (35 milliseconds)

3215[info] - HeaderDeserializer.monad.flatMap consistent apply (41 milliseconds)

3216[info] - HeaderDeserializer.monad.flatMap from tailRecM consistency (30 milliseconds)

3217[info] - HeaderDeserializer.monad.invariant composition (27 milliseconds)

3218[info] - HeaderDeserializer.monad.invariant identity (27 milliseconds)

3219[info] - HeaderDeserializer.monad.map flatMap coherence (25 milliseconds)

3220[info] - HeaderDeserializer.monad.map2/map2Eval consistency (28 milliseconds)

3221[info] - HeaderDeserializer.monad.map2/product-map consistency (33 milliseconds)

3222[info] - HeaderDeserializer.monad.mapOrKeepToMapEquivalence (31 milliseconds)

3223[info] - HeaderDeserializer.monad.monad left identity (23 milliseconds)

3224[info] - HeaderDeserializer.monad.monad right identity (16 milliseconds)

3225[info] - HeaderDeserializer.monad.monoidal left identity (19 milliseconds)

3226[info] - HeaderDeserializer.monad.monoidal right identity (17 milliseconds)

3227[info] - HeaderDeserializer.monad.mproduct consistent flatMap (37 milliseconds)

3228[info] - HeaderDeserializer.monad.productL consistent map2 (20 milliseconds)

3229[info] - HeaderDeserializer.monad.productR consistent map2 (18 milliseconds)

3230[info] - HeaderDeserializer.monad.replicateA_ consistent with replicateA.void (37 milliseconds)

3231[info] - HeaderDeserializer.monad.semigroupal associativity (43 milliseconds)

3232[info] - HeaderDeserializer.monad.tailRecM consistent flatMap (30 milliseconds)

3233[info] - HeaderDeserializer.monad.tailRecM stack safety (55 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 (3 milliseconds)

3240[info] - CommittableConsumerRecord.eqLaws.eq.reflexivity eq (2 milliseconds)

3241[info] - CommittableConsumerRecord.eqLaws.eq.symmetry eq (2 milliseconds)

3242[info] - CommittableConsumerRecord.eqLaws.eq.transitivity eq (5 milliseconds)

3243[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirst reference (3 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 (3 milliseconds)

3247[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with forall (2 milliseconds)

3248[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant composition (3 milliseconds)

3249[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant identity (2 milliseconds)

3250[info] - CommittableConsumerRecord.traverseLaws.traverse.dropWhile_ reference (3 milliseconds)

3251[info] - CommittableConsumerRecord.traverseLaws.traverse.exists consistent with find (3 milliseconds)

3252[info] - CommittableConsumerRecord.traverseLaws.traverse.exists is lazy (1 millisecond)

3253[info] - CommittableConsumerRecord.traverseLaws.traverse.filter_ reference (1 millisecond)

3254[info] - CommittableConsumerRecord.traverseLaws.traverse.fold reference (2 milliseconds)

3255[info] - CommittableConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (2 milliseconds)

3256[info] - CommittableConsumerRecord.traverseLaws.traverse.foldM identity (3 milliseconds)

3257[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (2 milliseconds)

3258[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight is lazy (3 milliseconds)

3259[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (4 milliseconds)

3260[info] - CommittableConsumerRecord.traverseLaws.traverse.forall consistent with exists (2 milliseconds)

3261[info] - CommittableConsumerRecord.traverseLaws.traverse.forall is lazy (1 millisecond)

3262[info] - CommittableConsumerRecord.traverseLaws.traverse.forall true if empty (2 milliseconds)

3263[info] - CommittableConsumerRecord.traverseLaws.traverse.get reference (3 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 (2 milliseconds)

3267[info] - CommittableConsumerRecord.traverseLaws.traverse.nonEmpty reference (2 milliseconds)

3268[info] - CommittableConsumerRecord.traverseLaws.traverse.ordered consistency (4 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 (2 milliseconds)

3272[info] - CommittableConsumerRecord.traverseLaws.traverse.toList reference (5 milliseconds)

3273[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse derive foldMap (2 milliseconds)

3274[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

3275[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse order consistency (2 milliseconds)

3276[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse parallel composition (2 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 (4 milliseconds)

3280[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (2 milliseconds)

3281[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (4 milliseconds)

3282[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref updated (4 milliseconds)

3283[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (3 milliseconds)

3284[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (3 milliseconds)

3285[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse sequential composition (4 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 (2 milliseconds)

3289[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (2 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 (4 milliseconds)

3293[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (2 milliseconds)

3294[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (2 milliseconds)

3295[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (2 milliseconds)

3296[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (2 milliseconds)

3297[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (3 milliseconds)

3298[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (2 milliseconds)

3301[info] - should have expected message and toString (1 millisecond)

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 (1 millisecond)

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 (1 millisecond)

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 (247 milliseconds)

3317[info] - Serializer[IO, *].contravariant.contravariant identity (133 milliseconds)

3318[info] - Serializer[IO, *].contravariant.invariant composition (126 milliseconds)

3319[info] - Serializer[IO, *].contravariant.invariant identity (104 milliseconds)

3320[info] - Serializer#mapBytes (9 milliseconds)

3321[info] - Serializer#apply (7 milliseconds)

3322[info] - Serializer#identity (6 milliseconds)

3323[info] - Serializer#const (8 milliseconds)

3324[info] - Serializer#defer (8 milliseconds)

3325[info] - Serializer#fail (5 milliseconds)

3326[info] - Serializer#failWith (7 milliseconds)

3327[info] - Serializer#suspend (16 milliseconds)

3328[info] - Serializer#headers (21 milliseconds)

3329[info] - Serializer#topic (15 milliseconds)

3330[info] - Serializer#topic.unknown (6 milliseconds)

3331[info] - Serializer#asNull (2 milliseconds)

3332[info] - Serializer#empty (2 milliseconds)

3333[info] - Serializer#option (3 milliseconds)

3334[info] - Serializer#unit (0 milliseconds)

3335[info] - Serializer#toString (1 millisecond)

3336[info] - Serializer#string (3 milliseconds)

3337[info] - Serializer#uuid (12 milliseconds)

3338[info] - Serializer#uuid.default (6 milliseconds)

3339[info] - Serializer#double (7 milliseconds)

3340[info] - Serializer#float (5 milliseconds)

3341[info] - Serializer#int (4 milliseconds)

3342[info] - Serializer#long (4 milliseconds)

3343[info] - Serializer#short (5 milliseconds)

3344[info] DeserializerSpec:

3345[info] - Deserializer[IO, *].monadError.ap consistent with product + map (190 milliseconds)

3346[info] - Deserializer[IO, *].monadError.applicative homomorphism (116 milliseconds)

3347[info] - Deserializer[IO, *].monadError.applicative identity (96 milliseconds)

3348[info] - Deserializer[IO, *].monadError.applicative interchange (108 milliseconds)

3349[info] - Deserializer[IO, *].monadError.applicative map (127 milliseconds)

3350[info] - Deserializer[IO, *].monadError.applicative unit (124 milliseconds)

3351[info] - Deserializer[IO, *].monadError.applicativeError adaptError pure (103 milliseconds)

3352[info] - Deserializer[IO, *].monadError.applicativeError adaptError raise (116 milliseconds)

3353[info] - Deserializer[IO, *].monadError.applicativeError attempt consistent with attemptT (86 milliseconds)

3354[info] - Deserializer[IO, *].monadError.applicativeError attempt fromEither consistent with pure (88 milliseconds)

3355[info] - Deserializer[IO, *].monadError.applicativeError handle (98 milliseconds)

3356[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError left-distributes over ap (155 milliseconds)

3357[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError right-distributes over ap (108 milliseconds)

3358[info] - Deserializer[IO, *].monadError.applicativeError handleError consistent with recover (64 milliseconds)

3359[info] - Deserializer[IO, *].monadError.applicativeError handleError pure (63 milliseconds)

3360[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith consistent with recoverWith (69 milliseconds)

3361[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith pure (54 milliseconds)

3362[info] - Deserializer[IO, *].monadError.applicativeError handleWith (63 milliseconds)

3363[info] - Deserializer[IO, *].monadError.applicativeError onError pure (71 milliseconds)

3364[info] - Deserializer[IO, *].monadError.applicativeError onError raise (90 milliseconds)

3365[info] - Deserializer[IO, *].monadError.applicativeError pure attempt (65 milliseconds)

3366[info] - Deserializer[IO, *].monadError.applicativeError raiseError attempt (80 milliseconds)

3367[info] - Deserializer[IO, *].monadError.applicativeError recover consistent with recoverWith (67 milliseconds)

3368[info] - Deserializer[IO, *].monadError.applicativeError redeem is derived from attempt and map (66 milliseconds)

3369[info] - Deserializer[IO, *].monadError.applicativeError voidError consistent with void+handleError (60 milliseconds)

3370[info] - Deserializer[IO, *].monadError.apply composition (68 milliseconds)

3371[info] - Deserializer[IO, *].monadError.covariant composition (74 milliseconds)

3372[info] - Deserializer[IO, *].monadError.covariant identity (67 milliseconds)

3373[info] - Deserializer[IO, *].monadError.flatMap associativity (65 milliseconds)

3374[info] - Deserializer[IO, *].monadError.flatMap consistent apply (67 milliseconds)

3375[info] - Deserializer[IO, *].monadError.flatMap from tailRecM consistency (76 milliseconds)

3376[info] - Deserializer[IO, *].monadError.invariant composition (69 milliseconds)

3377[info] - Deserializer[IO, *].monadError.invariant identity (61 milliseconds)

3378[info] - Deserializer[IO, *].monadError.map flatMap coherence (61 milliseconds)

3379[info] - Deserializer[IO, *].monadError.map2/map2Eval consistency (67 milliseconds)

3380[info] - Deserializer[IO, *].monadError.map2/product-map consistency (70 milliseconds)

3381[info] - Deserializer[IO, *].monadError.mapOrKeepToMapEquivalence (67 milliseconds)

3382[info] - Deserializer[IO, *].monadError.monad left identity (64 milliseconds)

3383[info] - Deserializer[IO, *].monadError.monad right identity (57 milliseconds)

3384[info] - Deserializer[IO, *].monadError.monadError ensure consistency (67 milliseconds)

3385[info] - Deserializer[IO, *].monadError.monadError ensureOr consistency (67 milliseconds)

3386[info] - Deserializer[IO, *].monadError.monadError left zero (75 milliseconds)

3387[info] - Deserializer[IO, *].monadError.monadError redeemWith is derived from attempt and flatMap (70 milliseconds)

3388[info] - Deserializer[IO, *].monadError.monadError rethrow attempt (74 milliseconds)

3389[info] - Deserializer[IO, *].monadError.monoidal left identity (65 milliseconds)

3390[info] - Deserializer[IO, *].monadError.monoidal right identity (56 milliseconds)

3391[info] - Deserializer[IO, *].monadError.mproduct consistent flatMap (135 milliseconds)

3392[info] - Deserializer[IO, *].monadError.productL consistent map2 (59 milliseconds)

3393[info] - Deserializer[IO, *].monadError.productR consistent map2 (66 milliseconds)

3394[info] - Deserializer[IO, *].monadError.replicateA_ consistent with replicateA.void (78 milliseconds)

3395[info] - Deserializer[IO, *].monadError.semigroupal associativity (74 milliseconds)

3396[info] - Deserializer[IO, *].monadError.tailRecM consistent flatMap (102 milliseconds)

3397[info] - Deserializer[IO, *].monadError.tailRecM stack safety (267 milliseconds)

3398[info] - Deserializer#attempt (6 milliseconds)

3399[info] - Deserializer#fail (4 milliseconds)

3400[info] - Deserializer#failWith (6 milliseconds)

3401[info] - Deserializer#headers (9 milliseconds)

3402[info] - Deserializer#apply (2 milliseconds)

3403[info] - Deserializer#identity (2 milliseconds)

3404[info] - Deserializer#suspend (6 milliseconds)

3405[info] - Deserializer#topic (6 milliseconds)

3406[info] - Deserializer#topic.unknown (6 milliseconds)

3407[info] - Deserializer#attempt (implicit) (7 milliseconds)

3408[info] - Deserializer#option (6 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 (0 milliseconds)

3422[info] - should concat empty (3 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) (1 millisecond)

3427[info] Headers#empty.asJava

3431[info] - lastHeader returns null (0 milliseconds)

3432[info] - headers returns empty iterable (0 milliseconds)

3433[info] - toArray returns empty array (1 millisecond)

3435[info] - iterator.hasNext returns false (0 milliseconds)

3436[info] Headers#nonEmpty.asJava

3440[info] - lastHeader returns last header (1 millisecond)

3441[info] - lastHeaders returns existing header (0 milliseconds)

3442[info] - lastHeader returns null for missing key (0 milliseconds)

3443[info] - headers returns matching headers (7 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 (1 millisecond)

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 (0 milliseconds)

3453[info] - should return false for non-existing key (0 milliseconds)

3454[info] - should concat empty (1 millisecond)

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) (1 millisecond)

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 (1 millisecond)

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 (4 milliseconds)

3474[info] KafkaHeaders#asScala

3475[info] - should convert empty (1 millisecond)

3476[info] - should convert non-empty (0 milliseconds)

3477[info] KafkaFuture.cancelable

3478Build timeout after 2 hours