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

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

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

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

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

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

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 Nov 28, 2025, 3:53:35 PM

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

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

136Starting build...

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

168[info] [patched file /build/repo/modules/core/src/main/scala/fs2/kafka/ProducerRecord.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/AvroSettings.scala]

173[info] [patched file /build/repo/modules/vulcan/src/main/scala/fs2/kafka/vulcan/SchemaRegistryClientSettings.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": 1009, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

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

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

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

208 "metadata": {

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

210}

211},{

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

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

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

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

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

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

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

235 "test-compile": {"status": "ok", "tookMs": 15331, "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: 115 s (0:01:55.0), completed Nov 28, 2025, 3:55:30 PM

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

245Checking patch build.sbt...

246Applied patch project/plugins.sbt cleanly.

247Applied patch build.sbt cleanly.

248Commit migration rewrites

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

250[opencb/migrate-source-3.4 b5ce12e8] 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-RC2

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-RC2"

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

267----

268Starting build for 3.8.0-RC2

269Execute tests: true

270sbt project found:

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

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

273Scala version: 3.8.0-RC2

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

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-RC2"

295"++3.8.0-RC2 -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-RC2 """{"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-RC2

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

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

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

314OpenCB::Changing crossVersion 3.8.0-RC2 -> 3.8.0-RC2 in vulcan-testkit-munit/crossScalaVersions

315OpenCB::Changing crossVersion 3.8.0-RC2 -> 3.8.0-RC2 in fs2-kafka/crossScalaVersions

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

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

318[info] Switching Scala version on:

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

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

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

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

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 Nov 28, 2025, 3:55:49 PM

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

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

360Starting build...

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

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

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

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

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

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

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

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

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

375[info] done compiling

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

377[info] done compiling

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

379[info] done compiling

380[info] PackageSpec:

381[info] avroSerializer

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

383[info] avroDeserializer

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

385[info] avroSerializer/avroDeserializer

38615:56:29.965 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

387 auto.register.schemas = true

388 avro.reflection.allow.null = false

389 avro.remove.java.properties = false

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

391 basic.auth.credentials.source = URL

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

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

394 bearer.auth.client.id = null

395 bearer.auth.client.secret = null

396 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

400 bearer.auth.logical.cluster = null

401 bearer.auth.scope = null

402 bearer.auth.scope.claim.name = scope

403 bearer.auth.sub.claim.name = sub

404 bearer.auth.token = [hidden]

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

406 http.connect.timeout.ms = 60000

407 http.read.timeout.ms = 60000

408 id.compatibility.strict = true

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

410 latest.cache.size = 1000

411 latest.cache.ttl.sec = -1

412 latest.compatibility.strict = true

413 max.retries = 3

414 max.schemas.per.subject = 1000

415 normalize.schemas = false

416 propagate.schema.tags = false

417 proxy.host =

418 proxy.port = -1

419 retries.max.wait.ms = 20000

420 retries.wait.ms = 1000

421 rule.actions = []

422 rule.executors = []

423 rule.service.loader.enable = true

424 schema.format = null

425 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

439 schema.registry.ssl.provider = null

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

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

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

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

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

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

446 schema.registry.url = []

447 schema.registry.url.randomize = false

448 use.latest.version = false

449 use.latest.with.metadata = null

450 use.schema.id = -1

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

45315:56:29.965 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

454 auto.register.schemas = true

455 avro.reflection.allow.null = false

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

457 basic.auth.credentials.source = URL

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

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

460 bearer.auth.client.id = null

461 bearer.auth.client.secret = null

462 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

466 bearer.auth.logical.cluster = null

467 bearer.auth.scope = null

468 bearer.auth.scope.claim.name = scope

469 bearer.auth.sub.claim.name = sub

470 bearer.auth.token = [hidden]

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

472 http.connect.timeout.ms = 60000

473 http.read.timeout.ms = 60000

474 id.compatibility.strict = true

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

476 latest.cache.size = 1000

477 latest.cache.ttl.sec = -1

478 latest.compatibility.strict = true

479 max.retries = 3

480 max.schemas.per.subject = 1000

481 normalize.schemas = false

482 propagate.schema.tags = false

483 proxy.host =

484 proxy.port = -1

485 retries.max.wait.ms = 20000

486 retries.wait.ms = 1000

487 rule.actions = []

488 rule.executors = []

489 rule.service.loader.enable = true

490 schema.format = null

491 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

505 schema.registry.ssl.provider = null

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

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

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

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

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

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

512 schema.registry.url = []

513 schema.registry.url.randomize = false

514 specific.avro.key.type = null

515 specific.avro.reader = false

516 specific.avro.value.type = null

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

52315:56:30.064 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

524 auto.register.schemas = true

525 avro.reflection.allow.null = false

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

527 basic.auth.credentials.source = URL

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

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

530 bearer.auth.client.id = null

531 bearer.auth.client.secret = null

532 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

536 bearer.auth.logical.cluster = null

537 bearer.auth.scope = null

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

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

540 bearer.auth.token = [hidden]

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

542 http.connect.timeout.ms = 60000

543 http.read.timeout.ms = 60000

544 id.compatibility.strict = true

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

546 latest.cache.size = 1000

547 latest.cache.ttl.sec = -1

548 latest.compatibility.strict = true

549 max.retries = 3

550 max.schemas.per.subject = 1000

551 normalize.schemas = false

552 propagate.schema.tags = false

553 proxy.host =

554 proxy.port = -1

555 retries.max.wait.ms = 20000

556 retries.wait.ms = 1000

557 rule.actions = []

558 rule.executors = []

559 rule.service.loader.enable = true

560 schema.format = null

561 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

575 schema.registry.ssl.provider = null

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

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

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

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

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

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

582 schema.registry.url = []

583 schema.registry.url.randomize = false

584 specific.avro.key.type = null

585 specific.avro.reader = false

586 specific.avro.value.type = null

587 use.latest.version = false

588 use.latest.with.metadata = null

589 use.schema.id = -1

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

59215:56:30.064 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

593 auto.register.schemas = true

594 avro.reflection.allow.null = false

595 avro.remove.java.properties = false

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

597 basic.auth.credentials.source = URL

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

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

600 bearer.auth.client.id = null

601 bearer.auth.client.secret = null

602 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

606 bearer.auth.logical.cluster = null

607 bearer.auth.scope = null

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

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

610 bearer.auth.token = [hidden]

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

612 http.connect.timeout.ms = 60000

613 http.read.timeout.ms = 60000

614 id.compatibility.strict = true

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

616 latest.cache.size = 1000

617 latest.cache.ttl.sec = -1

618 latest.compatibility.strict = true

619 max.retries = 3

620 max.schemas.per.subject = 1000

621 normalize.schemas = false

622 propagate.schema.tags = false

623 proxy.host =

624 proxy.port = -1

625 retries.max.wait.ms = 20000

626 retries.wait.ms = 1000

627 rule.actions = []

628 rule.executors = []

629 rule.service.loader.enable = true

630 schema.format = null

631 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

645 schema.registry.ssl.provider = null

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

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

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

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

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

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

652 schema.registry.url = []

653 schema.registry.url.randomize = false

654 use.latest.version = false

655 use.latest.with.metadata = null

656 use.schema.id = -1

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

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

66015:56:30.079 [io-compute-2] 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

72715:56:30.080 [io-compute-3] 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 (16 milliseconds)

797[info] AvroSettingsSpec:

798[info] AvroSettings

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

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

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

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

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

804[info] - should provide withProperties(Map) (2 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)

80915:56:30.284 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

810 auto.register.schemas = true

811 avro.reflection.allow.null = false

812 avro.remove.java.properties = false

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

814 basic.auth.credentials.source = URL

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

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

817 bearer.auth.client.id = null

818 bearer.auth.client.secret = null

819 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

823 bearer.auth.logical.cluster = null

824 bearer.auth.scope = null

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

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

827 bearer.auth.token = [hidden]

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

829 http.connect.timeout.ms = 60000

830 http.read.timeout.ms = 60000

831 id.compatibility.strict = true

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

833 latest.cache.size = 1000

834 latest.cache.ttl.sec = -1

835 latest.compatibility.strict = true

836 max.retries = 3

837 max.schemas.per.subject = 1000

838 normalize.schemas = false

839 propagate.schema.tags = false

840 proxy.host =

841 proxy.port = -1

842 retries.max.wait.ms = 20000

843 retries.wait.ms = 1000

844 rule.actions = []

845 rule.executors = []

846 rule.service.loader.enable = true

847 schema.format = null

848 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

862 schema.registry.ssl.provider = null

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

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

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

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

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

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

869 schema.registry.url = []

870 schema.registry.url.randomize = false

871 use.latest.version = false

872 use.latest.with.metadata = null

873 use.schema.id = -1

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

87615:56:30.289 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

877 auto.register.schemas = true

878 avro.reflection.allow.null = false

879 avro.remove.java.properties = false

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

881 basic.auth.credentials.source = URL

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

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

884 bearer.auth.client.id = null

885 bearer.auth.client.secret = null

886 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

890 bearer.auth.logical.cluster = null

891 bearer.auth.scope = null

892 bearer.auth.scope.claim.name = scope

893 bearer.auth.sub.claim.name = sub

894 bearer.auth.token = [hidden]

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

896 http.connect.timeout.ms = 60000

897 http.read.timeout.ms = 60000

898 id.compatibility.strict = true

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

900 latest.cache.size = 1000

901 latest.cache.ttl.sec = -1

902 latest.compatibility.strict = true

903 max.retries = 3

904 max.schemas.per.subject = 1000

905 normalize.schemas = false

906 propagate.schema.tags = false

907 proxy.host =

908 proxy.port = -1

909 retries.max.wait.ms = 20000

910 retries.wait.ms = 1000

911 rule.actions = []

912 rule.executors = []

913 rule.service.loader.enable = true

914 schema.format = null

915 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

929 schema.registry.ssl.provider = null

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

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

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

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

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

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

936 schema.registry.url = []

937 schema.registry.url.randomize = false

938 use.latest.version = false

939 use.latest.with.metadata = null

940 use.schema.id = -1

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

94315:56:30.292 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

944 auto.register.schemas = true

945 avro.reflection.allow.null = false

946 avro.remove.java.properties = false

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

948 basic.auth.credentials.source = URL

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

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

951 bearer.auth.client.id = null

952 bearer.auth.client.secret = null

953 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

957 bearer.auth.logical.cluster = null

958 bearer.auth.scope = null

959 bearer.auth.scope.claim.name = scope

960 bearer.auth.sub.claim.name = sub

961 bearer.auth.token = [hidden]

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

963 http.connect.timeout.ms = 60000

964 http.read.timeout.ms = 60000

965 id.compatibility.strict = true

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

967 latest.cache.size = 1000

968 latest.cache.ttl.sec = -1

969 latest.compatibility.strict = true

970 max.retries = 3

971 max.schemas.per.subject = 1000

972 normalize.schemas = false

973 propagate.schema.tags = false

974 proxy.host =

975 proxy.port = -1

976 retries.max.wait.ms = 20000

977 retries.wait.ms = 1000

978 rule.actions = []

979 rule.executors = []

980 rule.service.loader.enable = true

981 schema.format = null

982 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

996 schema.registry.ssl.provider = null

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

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

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

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

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

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

1003 schema.registry.url = []

1004 schema.registry.url.randomize = false

1005 use.latest.version = false

1006 use.latest.with.metadata = null

1007 use.schema.id = -1

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

1010[info] AvroSerializerSpec:

1011[info] AvroSerializer

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

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

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

1015[info] - toString (1 millisecond)

1016[info] AuthSpec:

1017[info] Auth.Basic

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

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

1020[info] Auth.Bearer

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

1022[info] Auth.None

1023[info] - should have None as toString (1 millisecond)

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

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

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

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

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

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

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

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

1036[info] AvroDeserializerSpec:

1037[info] AvroDeserializer

103815:56:30.413 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

1039 auto.register.schemas = true

1040 avro.reflection.allow.null = false

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

1042 basic.auth.credentials.source = URL

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

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

1045 bearer.auth.client.id = null

1046 bearer.auth.client.secret = null

1047 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

1051 bearer.auth.logical.cluster = null

1052 bearer.auth.scope = null

1053 bearer.auth.scope.claim.name = scope

1054 bearer.auth.sub.claim.name = sub

1055 bearer.auth.token = [hidden]

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

1057 http.connect.timeout.ms = 60000

1058 http.read.timeout.ms = 60000

1059 id.compatibility.strict = true

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

1061 latest.cache.size = 1000

1062 latest.cache.ttl.sec = -1

1063 latest.compatibility.strict = true

1064 max.retries = 3

1065 max.schemas.per.subject = 1000

1066 normalize.schemas = false

1067 propagate.schema.tags = false

1068 proxy.host =

1069 proxy.port = -1

1070 retries.max.wait.ms = 20000

1071 retries.wait.ms = 1000

1072 rule.actions = []

1073 rule.executors = []

1074 rule.service.loader.enable = true

1075 schema.format = null

1076 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

1090 schema.registry.ssl.provider = null

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

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

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

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

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

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

1097 schema.registry.url = []

1098 schema.registry.url.randomize = false

1099 specific.avro.key.type = null

1100 specific.avro.reader = false

1101 specific.avro.value.type = null

1102 use.latest.version = false

1103 use.latest.with.metadata = null

1104 use.schema.id = -1

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

110715:56:30.419 [io-compute-3] 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 (13 milliseconds)

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

117815:56:30.428 [io-compute-3] 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 (2 milliseconds)

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

1256[info] done compiling

1257[info] TimestampLawsSpec:

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

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

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

1261[info] - Timestamp.eqLaws.eq.transitivity eq (12 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 (270 milliseconds)

1271[info] Jitter#none

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

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

1276[info] ConsumerRecordLawsSpec:

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

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

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

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

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

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

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

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

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

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

1287[info] - ConsumerRecord.traverseLaws.traverse.covariant identity (6 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 (7 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1328[info] - ConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (6 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 (4 milliseconds)

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

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

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

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

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

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

1340[info] TimestampSpec:

1341[info] Timeout#createTime

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

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

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

1345[info] - should include the createTime in toString (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 (1 millisecond)

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

1351[info] Timeout#unknownTime

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

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

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

1355[info] - should include the unknownTime in toString (2 milliseconds)

1356[info] Timestamp#none

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

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

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

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

1365[info] KafkaSpec:

1366[info] commitBatchWithin

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

1368[info] ProducerRecordLawsSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1418[info] - ProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (6 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 (4 milliseconds)

1422[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (4 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 (2 milliseconds)

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

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

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

1429[info] AutoOffsetResetSpec:

1430[info] AutoOffsetReset

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

1432[info] ConsumerSettingsSpec:

1433[info] ConsumerSettings

1434[info] - should be able to set a custom blocking context (4 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 (1 millisecond)

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

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

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

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

1445[info] - should provide withHeartbeatInterval (1 millisecond)

1446[info] - should provide withEnableAutoCommit (2 milliseconds)

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

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

1449[info] - should provide withDefaultApiTimeout (1 millisecond)

1450[info] - should provide withIsolationLevel (1 millisecond)

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

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

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

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

1455[info] - should provide withPollInterval (1 millisecond)

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

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

1458[info] - should provide withRecordMetadata (2 milliseconds)

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

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

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

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

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

1466[info] HeaderSerializerSpec:

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

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

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

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

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

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

1473[info] - HeaderSerializer#asNull (3 milliseconds)

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

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

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

1477[info] - HeaderSerializer#toString (1 millisecond)

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

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

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

1481[info] - HeaderSerializer#float (3 milliseconds)

1482[info] - HeaderSerializer#int (1 millisecond)

1483[info] - HeaderSerializer#long (1 millisecond)

1484[info] - HeaderSerializer#short (2 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 (3 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 (11 milliseconds)

1496[info] - should override using the provided offset (20 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 (4 milliseconds)

1500[info] ProducerSettingsSpec:

1501[info] ProducerSettings

1502[info] - should provide apply (0 milliseconds)

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

1504[info] - should provide withAcks (2 milliseconds)

1505[info] - should provide withBatchSize (0 milliseconds)

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

1507[info] - should provide withRetries (1 millisecond)

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

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

1515[info] - should have a Show instance and matching toString (1 millisecond)

1516[info] - should be able to create with and without serializer creation effects (1 millisecond)

1517[info] - should be able to implicitly create with and without serializer creation effects (2 milliseconds)

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

1519[info] - should provide failFastProduce default value (0 milliseconds)

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

1521[info] ConsumerRecordSpec:

1522[info] ConsumerRecord#fromJava

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

1524[info] - should convert serialized key size (2 milliseconds)

1525[info] - should convert serialized value size (4 milliseconds)

1526[info] - should convert leader epoch (2 milliseconds)

1527[info] ConsumerRecord#toString

1528[info] - should include headers when present (1 millisecond)

1529[info] - should include timestamp if present (1 millisecond)

1530[info] - should include serialized key size if present (0 milliseconds)

1531[info] - should include serialized value size if present (1 millisecond)

1532[info] - should include leader epoch if present (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 (1 millisecond)

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

1548[info] - CommittableOffset.eqLaws.eq.symmetry eq (2 milliseconds)

1549[info] - CommittableOffset.eqLaws.eq.transitivity eq (3 milliseconds)

1550[info] CommittableProducerRecordsLawsSpec:

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

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

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

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

1555[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirst reference (7 milliseconds)

1556[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirstSome reference (4 milliseconds)

1557[info] - CommittableProducerRecord.traverseLaws.traverse.contains all elements from itself (7 milliseconds)

1558[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with exists (4 milliseconds)

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

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

1561[info] - CommittableProducerRecord.traverseLaws.traverse.covariant identity (4 milliseconds)

1562[info] - CommittableProducerRecord.traverseLaws.traverse.dropWhile_ reference (6 milliseconds)

1563[info] - CommittableProducerRecord.traverseLaws.traverse.exists consistent with find (3 milliseconds)

1564[info] - CommittableProducerRecord.traverseLaws.traverse.exists is lazy (4 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

1580[info] - CommittableProducerRecord.traverseLaws.traverse.ordered consistency (5 milliseconds)

1581[info] - CommittableProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (5 milliseconds)

1582[info] - CommittableProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (5 milliseconds)

1583[info] - CommittableProducerRecord.traverseLaws.traverse.takeWhile_ reference (5 milliseconds)

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

1585[info] - CommittableProducerRecord.traverseLaws.traverse.traverse derive foldMap (6 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 (5 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 (4 milliseconds)

1592[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (4 milliseconds)

1593[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (6 milliseconds)

1594[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref updated (5 milliseconds)

1595[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (7 milliseconds)

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

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

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

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

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

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

1602[info] - CommittableProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (3 milliseconds)

1603[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (5 milliseconds)

1604[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (5 milliseconds)

1605[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (3 milliseconds)

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

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

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

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

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

1611[info] HeaderDeserializerSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1634[info] - HeaderDeserializer.monad.mproduct consistent flatMap (42 milliseconds)

1635[info] - HeaderDeserializer.monad.productL consistent map2 (22 milliseconds)

1636[info] - HeaderDeserializer.monad.productR consistent map2 (18 milliseconds)

1637[info] - HeaderDeserializer.monad.replicateA_ consistent with replicateA.void (38 milliseconds)

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

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

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

1641[info] - HeaderDeserializer#delay (2 milliseconds)

1642[info] - HeaderDeserializer#option (2 milliseconds)

1643[info] - HeaderDeserializer#unit (1 millisecond)

1644[info] - HeaderDeserializer#toString (0 milliseconds)

1645[info] CommittableConsumerRecordLawsSpec:

1646[info] - CommittableConsumerRecord.eqLaws.eq.antisymmetry eq (7 milliseconds)

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

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

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

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

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

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

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

1657[info] - CommittableConsumerRecord.traverseLaws.traverse.dropWhile_ reference (3 milliseconds)

1658[info] - CommittableConsumerRecord.traverseLaws.traverse.exists consistent with find (3 milliseconds)

1659[info] - CommittableConsumerRecord.traverseLaws.traverse.exists is lazy (3 milliseconds)

1660[info] - CommittableConsumerRecord.traverseLaws.traverse.filter_ reference (2 milliseconds)

1661[info] - CommittableConsumerRecord.traverseLaws.traverse.fold reference (2 milliseconds)

1662[info] - CommittableConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (2 milliseconds)

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

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

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

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

1667[info] - CommittableConsumerRecord.traverseLaws.traverse.forall consistent with exists (1 millisecond)

1668[info] - CommittableConsumerRecord.traverseLaws.traverse.forall is lazy (2 milliseconds)

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

1672[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant identity (3 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 (3 milliseconds)

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

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

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

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

1680[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse derive foldMap (1 millisecond)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1695[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (3 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 (3 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 (5 milliseconds)

1702[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (3 milliseconds)

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

1712[info] - should have consistent toString and Show (0 milliseconds)

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

1716[info] - should deserialize with attemptAs (1 millisecond)

1717[info] HeaderLawsSpec:

1718[info] - Header.eqLaws.eq.antisymmetry eq (1 millisecond)

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

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

1721[info] - Header.eqLaws.eq.transitivity eq (1 millisecond)

1722[info] SerializerSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1741[info] - Serializer#unit (1 millisecond)

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

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

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

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

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

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

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

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

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

1751[info] DeserializerSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1815[info] - Deserializer#option (3 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 (0 milliseconds)

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

1831[info] - should return empty Chain from toChain (0 milliseconds)

1832[info] - should create a new Headers from append(Header) (0 milliseconds)

1833[info] - should create a new Headers from append(key, value) (0 milliseconds)

1834[info] Headers#empty.asJava

1838[info] - lastHeader returns null (1 millisecond)

1839[info] - headers returns empty iterable (0 milliseconds)

1840[info] - toArray returns empty array (1 millisecond)

1842[info] - iterator.hasNext returns false (0 milliseconds)

1843[info] Headers#nonEmpty.asJava

1847[info] - lastHeader returns last header (0 milliseconds)

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

1853[info] - iterator returns elements (0 milliseconds)

1854[info] Headers#nonEmpty

1855[info] - should not be empty (0 milliseconds)

1856[info] - should be non empty (1 millisecond)

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

1860[info] - should return false for non-existing key (0 milliseconds)

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

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

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 (4 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-RC2

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-RC2"

1903"++3.8.0-RC2 -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-RC2 """{"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-RC2

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

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

1921OpenCB::Changing crossVersion 3.8.0-RC2 -> 3.8.0-RC2 in vulcan/crossScalaVersions

1922OpenCB::Changing crossVersion 3.8.0-RC2 -> 3.8.0-RC2 in vulcan-testkit-munit/crossScalaVersions

1923OpenCB::Changing crossVersion 3.8.0-RC2 -> 3.8.0-RC2 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-RC2 on 4 projects.

1926[info] Switching Scala version on:

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

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

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

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

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 Nov 28, 2025, 5:45:44 PM

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

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

1968Starting build...

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

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

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

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

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

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

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

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

1977[info] PackageSpec:

1978[info] avroSerializer

1979[info] - should be available given explicit settings (362 milliseconds)

1980[info] avroDeserializer

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

1982[info] avroSerializer/avroDeserializer

198317:45:49.914 [io-compute-1] 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

205017:45:49.914 [io-compute-2] 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 (350 milliseconds)

212017:45:50.018 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2121 auto.register.schemas = true

2122 avro.reflection.allow.null = false

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

2124 basic.auth.credentials.source = URL

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

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

2127 bearer.auth.client.id = null

2128 bearer.auth.client.secret = null

2129 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

2133 bearer.auth.logical.cluster = null

2134 bearer.auth.scope = null

2135 bearer.auth.scope.claim.name = scope

2136 bearer.auth.sub.claim.name = sub

2137 bearer.auth.token = [hidden]

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

2139 http.connect.timeout.ms = 60000

2140 http.read.timeout.ms = 60000

2141 id.compatibility.strict = true

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

2143 latest.cache.size = 1000

2144 latest.cache.ttl.sec = -1

2145 latest.compatibility.strict = true

2146 max.retries = 3

2147 max.schemas.per.subject = 1000

2148 normalize.schemas = false

2149 propagate.schema.tags = false

2150 proxy.host =

2151 proxy.port = -1

2152 retries.max.wait.ms = 20000

2153 retries.wait.ms = 1000

2154 rule.actions = []

2155 rule.executors = []

2156 rule.service.loader.enable = true

2157 schema.format = null

2158 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

2172 schema.registry.ssl.provider = null

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

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

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

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

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

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

2179 schema.registry.url = []

2180 schema.registry.url.randomize = false

2181 specific.avro.key.type = null

2182 specific.avro.reader = false

2183 specific.avro.value.type = null

2184 use.latest.version = false

2185 use.latest.with.metadata = null

2186 use.schema.id = -1

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

218917:45:50.018 [io-compute-3] 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 (23 milliseconds)

225717:45:50.036 [io-compute-3] 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

232417:45:50.036 [io-compute-1] 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 (16 milliseconds)

2394[info] AvroSettingsSpec:

2395[info] AvroSettings

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

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

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

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

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

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

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

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

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

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

240617:45:50.244 [io-compute-1] 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

247517:45:50.250 [io-compute-2] 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 (9 milliseconds)

254317:45:50.255 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2544 auto.register.schemas = true

2545 avro.reflection.allow.null = false

2546 avro.remove.java.properties = false

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

2548 basic.auth.credentials.source = URL

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

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

2551 bearer.auth.client.id = null

2552 bearer.auth.client.secret = null

2553 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

2557 bearer.auth.logical.cluster = null

2558 bearer.auth.scope = null

2559 bearer.auth.scope.claim.name = scope

2560 bearer.auth.sub.claim.name = sub

2561 bearer.auth.token = [hidden]

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

2563 http.connect.timeout.ms = 60000

2564 http.read.timeout.ms = 60000

2565 id.compatibility.strict = true

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

2567 latest.cache.size = 1000

2568 latest.cache.ttl.sec = -1

2569 latest.compatibility.strict = true

2570 max.retries = 3

2571 max.schemas.per.subject = 1000

2572 normalize.schemas = false

2573 propagate.schema.tags = false

2574 proxy.host =

2575 proxy.port = -1

2576 retries.max.wait.ms = 20000

2577 retries.wait.ms = 1000

2578 rule.actions = []

2579 rule.executors = []

2580 rule.service.loader.enable = true

2581 schema.format = null

2582 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

2596 schema.registry.ssl.provider = null

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

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

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

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

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

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

2603 schema.registry.url = []

2604 schema.registry.url.randomize = false

2605 use.latest.version = false

2606 use.latest.with.metadata = null

2607 use.schema.id = -1

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

2610[info] - auto-registers union schemas (10 milliseconds)

2611[info] - raises schema errors (4 milliseconds)

2612[info] - toString (0 milliseconds)

2613[info] AuthSpec:

2614[info] Auth.Basic

2615[info] - should include the username in toString (6 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 (0 milliseconds)

2621[info] SchemaRegistryClientSettingsSpec:

2622[info] SchemaRegistryClientSettings

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

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

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

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

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

2628[info] - should provide withProperties (2 milliseconds)

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

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

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

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

2633[info] AvroDeserializerSpec:

2634[info] AvroDeserializer

263517:45:50.358 [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

270417:45:50.365 [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 (11 milliseconds)

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

277517:45:50.373 [io-compute-1] 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 (1 millisecond)

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

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

2853[info] - Timestamp.eqLaws.eq.symmetry eq (13 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 (2 milliseconds)

2861[info] JitterSpec:

2862[info] Jitter#default

2863[info] - should always apply jitter on values (265 milliseconds)

2864[info] Jitter#none

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

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

2869[info] ConsumerRecordLawsSpec:

2870[info] - ConsumerRecord.eqLaws.eq.antisymmetry eq (67 milliseconds)

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

2872[info] - ConsumerRecord.eqLaws.eq.symmetry eq (27 milliseconds)

2873[info] - ConsumerRecord.eqLaws.eq.transitivity eq (34 milliseconds)

2874[info] - ConsumerRecord.traverseLaws.traverse.collectFirst reference (28 milliseconds)

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

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

2877[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with exists (8 milliseconds)

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

2879[info] - ConsumerRecord.traverseLaws.traverse.covariant composition (9 milliseconds)

2880[info] - ConsumerRecord.traverseLaws.traverse.covariant identity (6 milliseconds)

2881[info] - ConsumerRecord.traverseLaws.traverse.dropWhile_ reference (10 milliseconds)

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

2883[info] - ConsumerRecord.traverseLaws.traverse.exists is lazy (6 milliseconds)

2884[info] - ConsumerRecord.traverseLaws.traverse.filter_ reference (7 milliseconds)

2885[info] - ConsumerRecord.traverseLaws.traverse.fold reference (4 milliseconds)

2886[info] - ConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (13 milliseconds)

2887[info] - ConsumerRecord.traverseLaws.traverse.foldM identity (17 milliseconds)

2888[info] - ConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (6 milliseconds)

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

2890[info] - ConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (8 milliseconds)

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

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

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

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

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

2896[info] - ConsumerRecord.traverseLaws.traverse.invariant identity (6 milliseconds)

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

2898[info] - ConsumerRecord.traverseLaws.traverse.nonEmpty reference (6 milliseconds)

2899[info] - ConsumerRecord.traverseLaws.traverse.ordered consistency (6 milliseconds)

2900[info] - ConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (5 milliseconds)

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

2902[info] - ConsumerRecord.traverseLaws.traverse.takeWhile_ reference (19 milliseconds)

2903[info] - ConsumerRecord.traverseLaws.traverse.toList reference (4 milliseconds)

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

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

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

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

2908[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (26 milliseconds)

2909[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (6 milliseconds)

2910[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (8 milliseconds)

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

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

2913[info] - ConsumerRecord.traverseLaws.traverse.traverse ref updated (8 milliseconds)

2914[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (5 milliseconds)

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

2916[info] - ConsumerRecord.traverseLaws.traverse.traverse sequential composition (16 milliseconds)

2917[info] - ConsumerRecord.traverseLaws.traverse.traverse traverseTap (8 milliseconds)

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

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

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

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

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

2923[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (6 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 (6 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 (19 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 (4 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 (0 milliseconds)

2943[info] - should include the logAppendTime in toString (1 millisecond)

2944[info] Timeout#unknownTime

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

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

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

2948[info] - should include the unknownTime in toString (2 milliseconds)

2949[info] Timestamp#none

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

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

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

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

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

2955[info] CommittableConsumerRecordSpec:

2956[info] CommittableConsumerRecord

2957[info] - should have a Show instance and matching toString (3 milliseconds)

2958[info] KafkaSpec:

2959[info] commitBatchWithin

2960[info] - should batch commit according specified arguments (150 milliseconds)

2961[info] ProducerRecordLawsSpec:

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

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

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

2965[info] - ProducerRecord.eqLaws.eq.transitivity eq (4 milliseconds)

2966[info] - ProducerRecord.traverseLaws.traverse.collectFirst reference (5 milliseconds)

2967[info] - ProducerRecord.traverseLaws.traverse.collectFirstSome reference (4 milliseconds)

2968[info] - ProducerRecord.traverseLaws.traverse.contains all elements from itself (4 milliseconds)

2969[info] - ProducerRecord.traverseLaws.traverse.contains consistent with exists (2 milliseconds)

2970[info] - ProducerRecord.traverseLaws.traverse.contains consistent with forall (2 milliseconds)

2971[info] - ProducerRecord.traverseLaws.traverse.covariant composition (3 milliseconds)

2972[info] - ProducerRecord.traverseLaws.traverse.covariant identity (3 milliseconds)

2973[info] - ProducerRecord.traverseLaws.traverse.dropWhile_ reference (4 milliseconds)

2974[info] - ProducerRecord.traverseLaws.traverse.exists consistent with find (9 milliseconds)

2975[info] - ProducerRecord.traverseLaws.traverse.exists is lazy (3 milliseconds)

2976[info] - ProducerRecord.traverseLaws.traverse.filter_ reference (3 milliseconds)

2977[info] - ProducerRecord.traverseLaws.traverse.fold reference (5 milliseconds)

2978[info] - ProducerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (10 milliseconds)

2979[info] - ProducerRecord.traverseLaws.traverse.foldM identity (6 milliseconds)

2980[info] - ProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (4 milliseconds)

2981[info] - ProducerRecord.traverseLaws.traverse.foldRight is lazy (3 milliseconds)

2982[info] - ProducerRecord.traverseLaws.traverse.foldRightDefer consistency (5 milliseconds)

2983[info] - ProducerRecord.traverseLaws.traverse.forall consistent with exists (4 milliseconds)

2984[info] - ProducerRecord.traverseLaws.traverse.forall is lazy (4 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 (10 milliseconds)

2988[info] - ProducerRecord.traverseLaws.traverse.invariant identity (3 milliseconds)

2989[info] - ProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (3 milliseconds)

2990[info] - ProducerRecord.traverseLaws.traverse.nonEmpty reference (3 milliseconds)

2991[info] - ProducerRecord.traverseLaws.traverse.ordered consistency (3 milliseconds)

2992[info] - ProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (2 milliseconds)

2993[info] - ProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (2 milliseconds)

2994[info] - ProducerRecord.traverseLaws.traverse.takeWhile_ reference (2 milliseconds)

2995[info] - ProducerRecord.traverseLaws.traverse.toList reference (1 millisecond)

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 (3 milliseconds)

3000[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (5 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 (5 milliseconds)

3004[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (2 milliseconds)

3005[info] - ProducerRecord.traverseLaws.traverse.traverse ref updated (2 milliseconds)

3006[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (3 milliseconds)

3007[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (2 milliseconds)

3008[info] - ProducerRecord.traverseLaws.traverse.traverse sequential composition (3 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 (3 milliseconds)

3013[info] - ProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (2 milliseconds)

3014[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (2 milliseconds)

3015[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (3 milliseconds)

3016[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (2 milliseconds)

3017[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (4 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 (3 milliseconds)

3021[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (2 milliseconds)

3022[info] AutoOffsetResetSpec:

3023[info] AutoOffsetReset

3024[info] - should have toString matching name (2 milliseconds)

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 (1 millisecond)

3031[info] - should provide withClientRack (0 milliseconds)

3032[info] - should provide withClientId (0 milliseconds)

3033[info] - should provide withGroupId (0 milliseconds)

3034[info] - should provide withGroupInstanceId (0 milliseconds)

3035[info] - should provide withMaxPollRecords (1 millisecond)

3036[info] - should provide withMaxPollInterval (0 milliseconds)

3037[info] - should provide withSessionTimeout (0 milliseconds)

3038[info] - should provide withHeartbeatInterval (0 milliseconds)

3039[info] - should provide withEnableAutoCommit (0 milliseconds)

3040[info] - should provide withAutoCommitInterval (1 millisecond)

3041[info] - should provide withRequestTimeout (0 milliseconds)

3042[info] - should provide withDefaultApiTimeout (2 milliseconds)

3043[info] - should provide withIsolationLevel (1 millisecond)

3044[info] - should provide withProperty (0 milliseconds)

3045[info] - should provide withProperties (0 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 (1 millisecond)

3052[info] - should provide withMaxPrefetchBatches (1 millisecond)

3053[info] - should be able to create with and without deserializer creation effects (0 milliseconds)

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 (1 millisecond)

3059[info] HeaderSerializerSpec:

3060[info] - HeaderSerializer.contravariant.contravariant composition (91 milliseconds)

3061[info] - HeaderSerializer.contravariant.contravariant identity (42 milliseconds)

3062[info] - HeaderSerializer.contravariant.invariant composition (46 milliseconds)

3063[info] - HeaderSerializer.contravariant.invariant identity (38 milliseconds)

3064[info] - HeaderSerializer#mapBytes (6 milliseconds)

3065[info] - HeaderSerializer#const (3 milliseconds)

3066[info] - HeaderSerializer#asNull (2 milliseconds)

3067[info] - HeaderSerializer#empty (3 milliseconds)

3068[info] - HeaderSerializer#option (2 milliseconds)

3069[info] - HeaderSerializer#unit (0 milliseconds)

3070[info] - HeaderSerializer#toString (0 milliseconds)

3071[info] - HeaderSerializer#string (7 milliseconds)

3072[info] - HeaderSerializer#uuid (6 milliseconds)

3073[info] - HeaderSerializer#double (1 millisecond)

3074[info] - HeaderSerializer#float (4 milliseconds)

3075[info] - HeaderSerializer#int (3 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 (1 millisecond)

3081[info] - Headers.eqLaws.eq.symmetry eq (3 milliseconds)

3082[info] - Headers.eqLaws.eq.transitivity eq (3 milliseconds)

3083[info] CommittableOffsetBatchSpec:

3084[info] CommittableOffsetBatch#empty

3085[info] - should have no offsets (0 milliseconds)

3086[info] - should return updated offset as batch (3 milliseconds)

3087[info] CommittableOffsetBatch#updated

3088[info] - should include the provided offset (10 milliseconds)

3089[info] - should override using the provided offset (23 milliseconds)

3090[info] - should be able to update with batch (16 milliseconds)

3091[info] CommittableOffsetBatch#toString

3092[info] - should provide a Show instance and matching toString (3 milliseconds)

3093[info] ProducerSettingsSpec:

3094[info] ProducerSettings

3095[info] - should provide apply (0 milliseconds)

3096[info] - should provide withBootstrapServers (1 millisecond)

3097[info] - should provide withAcks (2 milliseconds)

3098[info] - should provide withBatchSize (1 millisecond)

3099[info] - should provide withClientId (0 milliseconds)

3100[info] - should provide withRetries (1 millisecond)

3101[info] - should provide withMaxInFlightRequestsPerConnection (0 milliseconds)

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 (1 millisecond)

3110[info] - should be able to implicitly create with and without serializer creation effects (2 milliseconds)

3111[info] - should be able to set a custom blocking context (0 milliseconds)

3112[info] - should provide failFastProduce default value (0 milliseconds)

3113[info] - should be able to set failFastProduce (1 millisecond)

3114[info] ConsumerRecordSpec:

3115[info] ConsumerRecord#fromJava

3116[info] - should convert timestamps (11 milliseconds)

3117[info] - should convert serialized key size (2 milliseconds)

3118[info] - should convert serialized value size (1 millisecond)

3119[info] - should convert leader epoch (4 milliseconds)

3120[info] ConsumerRecord#toString

3121[info] - should include headers when present (1 millisecond)

3122[info] - should include timestamp if present (1 millisecond)

3123[info] - should include serialized key size if present (0 milliseconds)

3124[info] - should include serialized value size if present (0 milliseconds)

3125[info] - should include leader epoch if present (0 milliseconds)

3126[info] AcksSpec:

3127[info] Acks

3128[info] - should have toString matching name (0 milliseconds)

3129[info] CommitRecoverySpec:

3130[info] CommitRecovery#Default

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 (1 millisecond)

3140[info] - CommittableOffset.eqLaws.eq.reflexivity eq (1 millisecond)

3141[info] - CommittableOffset.eqLaws.eq.symmetry eq (2 milliseconds)

3142[info] - CommittableOffset.eqLaws.eq.transitivity eq (2 milliseconds)

3143[info] CommittableProducerRecordsLawsSpec:

3144[info] - CommittableProducerRecord.eqLaws.eq.antisymmetry eq (10 milliseconds)

3145[info] - CommittableProducerRecord.eqLaws.eq.reflexivity eq (4 milliseconds)

3146[info] - CommittableProducerRecord.eqLaws.eq.symmetry eq (4 milliseconds)

3147[info] - CommittableProducerRecord.eqLaws.eq.transitivity eq (6 milliseconds)

3148[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirst reference (7 milliseconds)

3149[info] - CommittableProducerRecord.traverseLaws.traverse.collectFirstSome reference (5 milliseconds)

3150[info] - CommittableProducerRecord.traverseLaws.traverse.contains all elements from itself (5 milliseconds)

3151[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with exists (5 milliseconds)

3152[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with forall (6 milliseconds)

3153[info] - CommittableProducerRecord.traverseLaws.traverse.covariant composition (13 milliseconds)

3154[info] - CommittableProducerRecord.traverseLaws.traverse.covariant identity (3 milliseconds)

3155[info] - CommittableProducerRecord.traverseLaws.traverse.dropWhile_ reference (4 milliseconds)

3156[info] - CommittableProducerRecord.traverseLaws.traverse.exists consistent with find (4 milliseconds)

3157[info] - CommittableProducerRecord.traverseLaws.traverse.exists is lazy (4 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 (7 milliseconds)

3161[info] - CommittableProducerRecord.traverseLaws.traverse.foldM identity (6 milliseconds)

3162[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (7 milliseconds)

3163[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight is lazy (3 milliseconds)

3164[info] - CommittableProducerRecord.traverseLaws.traverse.foldRightDefer consistency (5 milliseconds)

3165[info] - CommittableProducerRecord.traverseLaws.traverse.forall consistent with exists (8 milliseconds)

3166[info] - CommittableProducerRecord.traverseLaws.traverse.forall is lazy (5 milliseconds)

3167[info] - CommittableProducerRecord.traverseLaws.traverse.forall true if empty (5 milliseconds)

3168[info] - CommittableProducerRecord.traverseLaws.traverse.get reference (6 milliseconds)

3169[info] - CommittableProducerRecord.traverseLaws.traverse.invariant composition (8 milliseconds)

3170[info] - CommittableProducerRecord.traverseLaws.traverse.invariant identity (7 milliseconds)

3171[info] - CommittableProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (5 milliseconds)

3172[info] - CommittableProducerRecord.traverseLaws.traverse.nonEmpty reference (5 milliseconds)

3173[info] - CommittableProducerRecord.traverseLaws.traverse.ordered consistency (7 milliseconds)

3174[info] - CommittableProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (4 milliseconds)

3175[info] - CommittableProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (6 milliseconds)

3176[info] - CommittableProducerRecord.traverseLaws.traverse.takeWhile_ reference (6 milliseconds)

3177[info] - CommittableProducerRecord.traverseLaws.traverse.toList reference (4 milliseconds)

3178[info] - CommittableProducerRecord.traverseLaws.traverse.traverse derive foldMap (8 milliseconds)

3179[info] - CommittableProducerRecord.traverseLaws.traverse.traverse identity (7 milliseconds)

3180[info] - CommittableProducerRecord.traverseLaws.traverse.traverse order consistency (6 milliseconds)

3181[info] - CommittableProducerRecord.traverseLaws.traverse.traverse parallel composition (4 milliseconds)

3182[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (7 milliseconds)

3183[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (5 milliseconds)

3184[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (5 milliseconds)

3185[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (3 milliseconds)

3186[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (6 milliseconds)

3187[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref updated (3 milliseconds)

3188[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (6 milliseconds)

3189[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (6 milliseconds)

3190[info] - CommittableProducerRecord.traverseLaws.traverse.traverse sequential composition (6 milliseconds)

3191[info] - CommittableProducerRecord.traverseLaws.traverse.traverse traverseTap (3 milliseconds)

3192[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (5 milliseconds)

3193[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (13 milliseconds)

3194[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse sequential composition (6 milliseconds)

3195[info] - CommittableProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (3 milliseconds)

3196[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (4 milliseconds)

3197[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (5 milliseconds)

3198[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (4 milliseconds)

3199[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (4 milliseconds)

3200[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (4 milliseconds)

3201[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (4 milliseconds)

3202[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (4 milliseconds)

3203[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (2 milliseconds)

3204[info] HeaderDeserializerSpec:

3205[info] - HeaderDeserializer.monad.ap consistent with product + map (49 milliseconds)

3206[info] - HeaderDeserializer.monad.applicative homomorphism (39 milliseconds)

3207[info] - HeaderDeserializer.monad.applicative identity (32 milliseconds)

3208[info] - HeaderDeserializer.monad.applicative interchange (35 milliseconds)

3209[info] - HeaderDeserializer.monad.applicative map (44 milliseconds)

3210[info] - HeaderDeserializer.monad.applicative unit (42 milliseconds)

3211[info] - HeaderDeserializer.monad.apply composition (51 milliseconds)

3212[info] - HeaderDeserializer.monad.covariant composition (34 milliseconds)

3213[info] - HeaderDeserializer.monad.covariant identity (22 milliseconds)

3214[info] - HeaderDeserializer.monad.flatMap associativity (46 milliseconds)

3215[info] - HeaderDeserializer.monad.flatMap consistent apply (29 milliseconds)

3216[info] - HeaderDeserializer.monad.flatMap from tailRecM consistency (30 milliseconds)

3217[info] - HeaderDeserializer.monad.invariant composition (25 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 (29 milliseconds)

3222[info] - HeaderDeserializer.monad.mapOrKeepToMapEquivalence (19 milliseconds)

3223[info] - HeaderDeserializer.monad.monad left identity (22 milliseconds)

3224[info] - HeaderDeserializer.monad.monad right identity (25 milliseconds)

3225[info] - HeaderDeserializer.monad.monoidal left identity (26 milliseconds)

3226[info] - HeaderDeserializer.monad.monoidal right identity (21 milliseconds)

3227[info] - HeaderDeserializer.monad.mproduct consistent flatMap (37 milliseconds)

3228[info] - HeaderDeserializer.monad.productL consistent map2 (17 milliseconds)

3229[info] - HeaderDeserializer.monad.productR consistent map2 (16 milliseconds)

3230[info] - HeaderDeserializer.monad.replicateA_ consistent with replicateA.void (41 milliseconds)

3231[info] - HeaderDeserializer.monad.semigroupal associativity (36 milliseconds)

3232[info] - HeaderDeserializer.monad.tailRecM consistent flatMap (29 milliseconds)

3233[info] - HeaderDeserializer.monad.tailRecM stack safety (35 milliseconds)

3234[info] - HeaderDeserializer#delay (2 milliseconds)

3235[info] - HeaderDeserializer#option (2 milliseconds)

3236[info] - HeaderDeserializer#unit (1 millisecond)

3237[info] - HeaderDeserializer#toString (0 milliseconds)

3238[info] CommittableConsumerRecordLawsSpec:

3239[info] - CommittableConsumerRecord.eqLaws.eq.antisymmetry eq (5 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 (3 milliseconds)

3243[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirst reference (3 milliseconds)

3244[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirstSome reference (3 milliseconds)

3245[info] - CommittableConsumerRecord.traverseLaws.traverse.contains all elements from itself (3 milliseconds)

3246[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with exists (3 milliseconds)

3247[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with forall (3 milliseconds)

3248[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant composition (4 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 (2 milliseconds)

3252[info] - CommittableConsumerRecord.traverseLaws.traverse.exists is lazy (2 milliseconds)

3253[info] - CommittableConsumerRecord.traverseLaws.traverse.filter_ reference (3 milliseconds)

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 (4 milliseconds)

3258[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight is lazy (2 milliseconds)

3259[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (2 milliseconds)

3260[info] - CommittableConsumerRecord.traverseLaws.traverse.forall consistent with exists (1 millisecond)

3261[info] - CommittableConsumerRecord.traverseLaws.traverse.forall is lazy (2 milliseconds)

3262[info] - CommittableConsumerRecord.traverseLaws.traverse.forall true if empty (2 milliseconds)

3263[info] - CommittableConsumerRecord.traverseLaws.traverse.get reference (3 milliseconds)

3264[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant composition (2 milliseconds)

3265[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant identity (2 milliseconds)

3266[info] - CommittableConsumerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (3 milliseconds)

3267[info] - CommittableConsumerRecord.traverseLaws.traverse.nonEmpty reference (1 millisecond)

3268[info] - CommittableConsumerRecord.traverseLaws.traverse.ordered consistency (3 milliseconds)

3269[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (3 milliseconds)

3270[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (3 milliseconds)

3271[info] - CommittableConsumerRecord.traverseLaws.traverse.takeWhile_ reference (5 milliseconds)

3272[info] - CommittableConsumerRecord.traverseLaws.traverse.toList reference (2 milliseconds)

3273[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse derive foldMap (4 milliseconds)

3274[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

3275[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse order consistency (3 milliseconds)

3276[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse parallel composition (2 milliseconds)

3277[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (4 milliseconds)

3278[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (8 milliseconds)

3279[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (4 milliseconds)

3280[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (5 milliseconds)

3281[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (4 milliseconds)

3282[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref updated (3 milliseconds)

3283[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (4 milliseconds)

3284[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (3 milliseconds)

3285[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse sequential composition (2 milliseconds)

3286[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse traverseTap (4 milliseconds)

3287[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (3 milliseconds)

3288[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (2 milliseconds)

3289[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (3 milliseconds)

3290[info] - CommittableConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (2 milliseconds)

3291[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (2 milliseconds)

3292[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (3 milliseconds)

3293[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (2 milliseconds)

3294[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (3 milliseconds)

3295[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (3 milliseconds)

3296[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (3 milliseconds)

3297[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (3 milliseconds)

3298[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 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 (1 millisecond)

3307[info] - should return the value with value (0 milliseconds)

3308[info] - should deserialize with as (1 millisecond)

3309[info] - should deserialize with attemptAs (0 milliseconds)

3310[info] HeaderLawsSpec:

3311[info] - Header.eqLaws.eq.antisymmetry eq (2 milliseconds)

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 (2 milliseconds)

3315[info] SerializerSpec:

3316[info] - Serializer[IO, *].contravariant.contravariant composition (214 milliseconds)

3317[info] - Serializer[IO, *].contravariant.contravariant identity (266 milliseconds)

3318[info] - Serializer[IO, *].contravariant.invariant composition (189 milliseconds)

3319[info] - Serializer[IO, *].contravariant.invariant identity (88 milliseconds)

3320[info] - Serializer#mapBytes (5 milliseconds)

3321[info] - Serializer#apply (6 milliseconds)

3322[info] - Serializer#identity (4 milliseconds)

3323[info] - Serializer#const (4 milliseconds)

3324[info] - Serializer#defer (8 milliseconds)

3325[info] - Serializer#fail (10 milliseconds)

3326[info] - Serializer#failWith (9 milliseconds)

3327[info] - Serializer#suspend (5 milliseconds)

3328[info] - Serializer#headers (11 milliseconds)

3329[info] - Serializer#topic (10 milliseconds)

3330[info] - Serializer#topic.unknown (7 milliseconds)

3331[info] - Serializer#asNull (1 millisecond)

3332[info] - Serializer#empty (1 millisecond)

3333[info] - Serializer#option (3 milliseconds)

3334[info] - Serializer#unit (1 millisecond)

3335[info] - Serializer#toString (0 milliseconds)

3336[info] - Serializer#string (7 milliseconds)

3337[info] - Serializer#uuid (7 milliseconds)

3338[info] - Serializer#uuid.default (8 milliseconds)

3339[info] - Serializer#double (4 milliseconds)

3340[info] - Serializer#float (5 milliseconds)

3341[info] - Serializer#int (3 milliseconds)

3342[info] - Serializer#long (5 milliseconds)

3343[info] - Serializer#short (4 milliseconds)

3344[info] DeserializerSpec:

3345[info] - Deserializer[IO, *].monadError.ap consistent with product + map (187 milliseconds)

3346[info] - Deserializer[IO, *].monadError.applicative homomorphism (95 milliseconds)

3347[info] - Deserializer[IO, *].monadError.applicative identity (117 milliseconds)

3348[info] - Deserializer[IO, *].monadError.applicative interchange (110 milliseconds)

3349[info] - Deserializer[IO, *].monadError.applicative map (78 milliseconds)

3350[info] - Deserializer[IO, *].monadError.applicative unit (70 milliseconds)

3351[info] - Deserializer[IO, *].monadError.applicativeError adaptError pure (95 milliseconds)

3352[info] - Deserializer[IO, *].monadError.applicativeError adaptError raise (105 milliseconds)

3353[info] - Deserializer[IO, *].monadError.applicativeError attempt consistent with attemptT (90 milliseconds)

3354[info] - Deserializer[IO, *].monadError.applicativeError attempt fromEither consistent with pure (86 milliseconds)

3355[info] - Deserializer[IO, *].monadError.applicativeError handle (142 milliseconds)

3356[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError left-distributes over ap (107 milliseconds)

3357[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError right-distributes over ap (100 milliseconds)

3358[info] - Deserializer[IO, *].monadError.applicativeError handleError consistent with recover (71 milliseconds)

3359[info] - Deserializer[IO, *].monadError.applicativeError handleError pure (66 milliseconds)

3360[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith consistent with recoverWith (64 milliseconds)

3361[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith pure (62 milliseconds)

3362[info] - Deserializer[IO, *].monadError.applicativeError handleWith (73 milliseconds)

3363[info] - Deserializer[IO, *].monadError.applicativeError onError pure (66 milliseconds)

3364[info] - Deserializer[IO, *].monadError.applicativeError onError raise (93 milliseconds)

3365[info] - Deserializer[IO, *].monadError.applicativeError pure attempt (67 milliseconds)

3366[info] - Deserializer[IO, *].monadError.applicativeError raiseError attempt (70 milliseconds)

3367[info] - Deserializer[IO, *].monadError.applicativeError recover consistent with recoverWith (64 milliseconds)

3368[info] - Deserializer[IO, *].monadError.applicativeError redeem is derived from attempt and map (80 milliseconds)

3369[info] - Deserializer[IO, *].monadError.applicativeError voidError consistent with void+handleError (63 milliseconds)

3370[info] - Deserializer[IO, *].monadError.apply composition (69 milliseconds)

3371[info] - Deserializer[IO, *].monadError.covariant composition (66 milliseconds)

3372[info] - Deserializer[IO, *].monadError.covariant identity (78 milliseconds)

3373[info] - Deserializer[IO, *].monadError.flatMap associativity (76 milliseconds)

3374[info] - Deserializer[IO, *].monadError.flatMap consistent apply (66 milliseconds)

3375[info] - Deserializer[IO, *].monadError.flatMap from tailRecM consistency (77 milliseconds)

3376[info] - Deserializer[IO, *].monadError.invariant composition (63 milliseconds)

3377[info] - Deserializer[IO, *].monadError.invariant identity (59 milliseconds)

3378[info] - Deserializer[IO, *].monadError.map flatMap coherence (74 milliseconds)

3379[info] - Deserializer[IO, *].monadError.map2/map2Eval consistency (67 milliseconds)

3380[info] - Deserializer[IO, *].monadError.map2/product-map consistency (77 milliseconds)

3381[info] - Deserializer[IO, *].monadError.mapOrKeepToMapEquivalence (73 milliseconds)

3382[info] - Deserializer[IO, *].monadError.monad left identity (65 milliseconds)

3383[info] - Deserializer[IO, *].monadError.monad right identity (81 milliseconds)

3384[info] - Deserializer[IO, *].monadError.monadError ensure consistency (68 milliseconds)

3385[info] - Deserializer[IO, *].monadError.monadError ensureOr consistency (64 milliseconds)

3386[info] - Deserializer[IO, *].monadError.monadError left zero (68 milliseconds)

3387[info] - Deserializer[IO, *].monadError.monadError redeemWith is derived from attempt and flatMap (64 milliseconds)

3388[info] - Deserializer[IO, *].monadError.monadError rethrow attempt (68 milliseconds)

3389[info] - Deserializer[IO, *].monadError.monoidal left identity (72 milliseconds)

3390[info] - Deserializer[IO, *].monadError.monoidal right identity (64 milliseconds)

3391[info] - Deserializer[IO, *].monadError.mproduct consistent flatMap (141 milliseconds)

3392[info] - Deserializer[IO, *].monadError.productL consistent map2 (60 milliseconds)

3393[info] - Deserializer[IO, *].monadError.productR consistent map2 (66 milliseconds)

3394[info] - Deserializer[IO, *].monadError.replicateA_ consistent with replicateA.void (79 milliseconds)

3395[info] - Deserializer[IO, *].monadError.semigroupal associativity (66 milliseconds)

3396[info] - Deserializer[IO, *].monadError.tailRecM consistent flatMap (101 milliseconds)

3397[info] - Deserializer[IO, *].monadError.tailRecM stack safety (347 milliseconds)

3398[info] - Deserializer#attempt (7 milliseconds)

3399[info] - Deserializer#fail (2 milliseconds)

3400[info] - Deserializer#failWith (2 milliseconds)

3401[info] - Deserializer#headers (11 milliseconds)

3402[info] - Deserializer#apply (2 milliseconds)

3403[info] - Deserializer#identity (2 milliseconds)

3404[info] - Deserializer#suspend (3 milliseconds)

3405[info] - Deserializer#topic (7 milliseconds)

3406[info] - Deserializer#topic.unknown (4 milliseconds)

3407[info] - Deserializer#attempt (implicit) (3 milliseconds)

3408[info] - Deserializer#option (3 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 (1 millisecond)

3421[info] - should not find any key (0 milliseconds)

3422[info] - should concat empty (0 milliseconds)

3423[info] - should concat non-empty (0 milliseconds)

3424[info] - should return empty Chain from toChain (0 milliseconds)

3425[info] - should create a new Headers from append(Header) (0 milliseconds)

3426[info] - should create a new Headers from append(key, value) (0 milliseconds)

3427[info] Headers#empty.asJava

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 (0 milliseconds)

3441[info] - lastHeaders returns existing header (0 milliseconds)

3442[info] - lastHeader returns null for missing key (0 milliseconds)

3443[info] - headers returns matching headers (5 milliseconds)

3444[info] - headers returns empty if no matching headers (0 milliseconds)

3445[info] - toArray returns elements (1 millisecond)

3446[info] - iterator returns elements (0 milliseconds)

3447[info] Headers#nonEmpty

3448[info] - should not be empty (0 milliseconds)

3449[info] - should be non empty (0 milliseconds)

3450[info] - should find an existing key (0 milliseconds)

3451[info] - should find the first key (1 millisecond)

3452[info] - should return true for existing key (1 millisecond)

3453[info] - should return false for non-existing key (1 millisecond)

3454[info] - should concat empty (0 milliseconds)

3455[info] - should concat non-empty (1 millisecond)

3456[info] - should include the headers in toString (0 milliseconds)

3457[info] - should append one more header with append(Header) (0 milliseconds)

3458[info] - should append one more header with append(key, value) (0 milliseconds)

3459[info] Headers#apply

3460[info] - returns empty for no headers (0 milliseconds)

3461[info] - returns non-empty for at least one header (0 milliseconds)

3462[info] Headers#fromChain

3463[info] - returns empty for empty chain (0 milliseconds)

3464[info] - returns non-empty for non-empty chain (0 milliseconds)

3465[info] Headers#fromSeq

3466[info] - returns empty for empty seq (0 milliseconds)

3467[info] - returns non-empty for non-empty seq (0 milliseconds)

3468[info] Headers#fromIterable

3469[info] - returns empty for empty iterable (0 milliseconds)

3470[info] - returns non-empty for non-empty iterable (0 milliseconds)

3471[info] SyntaxSpec:

3472[info] Map#filterKeysStrictValuesList

3473[info] - should be the same as toList.collect (3 milliseconds)

3474[info] KafkaHeaders#asScala

3475[info] - should convert empty (1 millisecond)

3476[info] - should convert non-empty (1 millisecond)

3477[info] KafkaFuture.cancelable

3478Build timeout after 2 hours