Build Logs

fd4s/fs2-kafka • 3.8.0-RC5:2025-12-31

Errors

Warnings

Total Lines

3478

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

82[info] done compiling

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

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

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

86Execute setCrossScalaVersions: 3.7.4

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

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

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

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

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

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

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

94[info] Switching Scala version on:

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

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

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

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

99[info] Excluding projects:

100[info] docs (2.13.17)

101[info] Reapplying settings...

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

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

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

105[info] Reapplying settings...

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

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

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

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

110[info] Run `last` for details.

111[info] Reapplying settings...

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

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

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

115[info] Reapplying settings...

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

117

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

119 Did you mean allExcludeDependencies ?

120 , retry without global scopes

121[info] Reapplying settings...

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

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

124Execute removeScalacOptionsStartingWith: -P:wartremover

125[info] Reapplying settings...

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

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

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

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

130[info] Reapplying settings...

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

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

133[success] Total time: 0 s, completed Dec 31, 2025, 10:15:55 PM

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

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

136Starting build...

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

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

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

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

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

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

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

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

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

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

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

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

149[warn] | ^

150[warn] | unused implicit parameter

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

169[warn] one warning found

170[info] done compiling

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

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

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

174[info] done compiling

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

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

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

178[warn] | ^

179[warn] | unused implicit parameter

180[warn] one warning found

181[info] done compiling

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

183[info] done compiling

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

185[info] done compiling

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

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

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

189[info] done compiling

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

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

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

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

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

195[info] done compiling

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

197[info] done compiling

198

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

200Build summary:

201[{

202 "module": "fs2-kafka",

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

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

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

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

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

208 "metadata": {

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

210}

211},{

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

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

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

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

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

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

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

235 "test-compile": {"status": "ok", "tookMs": 15460, "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: 65 s (0:01:05.0), completed Dec 31, 2025, 10:17:01 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 0e5a3f03] 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-RC5

254Scala binary version found: 3.8

255Implicitly using source version 3.8

256Scala binary version found: 3.8

257Implicitly using source version 3.8

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

259Append: ,REQUIRE:-source:3.8

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

261

262Try apply source patch:

263Path: build.sbt

264Pattern: val scala3 = "3.3.6"

265Replacement: val scala3 = "3.8.0-RC5"

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

267----

268Starting build for 3.8.0-RC5

269Execute tests: true

270sbt project found:

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

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

273Scala version: 3.8.0-RC5

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

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

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

303

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

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

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

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

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

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

310Execute setCrossScalaVersions: 3.8.0-RC5

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

312OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in vulcan/crossScalaVersions

313OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in vulcan-testkit-munit/crossScalaVersions

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

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

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

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

318[info] Switching Scala version on:

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

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

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

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

323[info] Excluding projects:

324[info] docs (2.13.17)

325[info] Reapplying settings...

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

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

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

329[info] Reapplying settings...

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

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

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

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

334[info] Run `last` for details.

335[info] Reapplying settings...

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

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

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

339[info] Reapplying settings...

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

341

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

343 Did you mean allExcludeDependencies ?

344 , retry without global scopes

345[info] Reapplying settings...

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

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

348Execute removeScalacOptionsStartingWith: -P:wartremover

349[info] Reapplying settings...

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

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

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

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

354[info] Reapplying settings...

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

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

357[success] Total time: 0 s, completed Dec 31, 2025, 10:17:19 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-RC5/classes ...

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

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

372[warn] | ^

373[warn] | unused implicit parameter

374[warn] one warning found

375[info] done compiling

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

377[info] done compiling

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

379[info] done compiling

380[info] PackageSpec:

381[info] avroSerializer

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

383[info] avroDeserializer

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

385[info] avroSerializer/avroDeserializer

38622:17:49.180 [io-compute-1] 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

452

45322:17:49.180 [io-compute-3] 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

521

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

52322:17:49.301 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

524 auto.register.schemas = true

525 avro.reflection.allow.null = false

526 avro.remove.java.properties = false

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

528 basic.auth.credentials.source = URL

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

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

531 bearer.auth.client.id = null

532 bearer.auth.client.secret = null

533 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

537 bearer.auth.logical.cluster = null

538 bearer.auth.scope = null

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

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

541 bearer.auth.token = [hidden]

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

543 http.connect.timeout.ms = 60000

544 http.read.timeout.ms = 60000

545 id.compatibility.strict = true

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

547 latest.cache.size = 1000

548 latest.cache.ttl.sec = -1

549 latest.compatibility.strict = true

550 max.retries = 3

551 max.schemas.per.subject = 1000

552 normalize.schemas = false

553 propagate.schema.tags = false

554 proxy.host =

555 proxy.port = -1

556 retries.max.wait.ms = 20000

557 retries.wait.ms = 1000

558 rule.actions = []

559 rule.executors = []

560 rule.service.loader.enable = true

561 schema.format = null

562 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

576 schema.registry.ssl.provider = null

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

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

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

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

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

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

583 schema.registry.url = []

584 schema.registry.url.randomize = false

585 use.latest.version = false

586 use.latest.with.metadata = null

587 use.schema.id = -1

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

589

59022:17:49.306 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

591 auto.register.schemas = true

592 avro.reflection.allow.null = false

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

594 basic.auth.credentials.source = URL

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

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

597 bearer.auth.client.id = null

598 bearer.auth.client.secret = null

599 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

603 bearer.auth.logical.cluster = null

604 bearer.auth.scope = null

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

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

607 bearer.auth.token = [hidden]

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

609 http.connect.timeout.ms = 60000

610 http.read.timeout.ms = 60000

611 id.compatibility.strict = true

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

613 latest.cache.size = 1000

614 latest.cache.ttl.sec = -1

615 latest.compatibility.strict = true

616 max.retries = 3

617 max.schemas.per.subject = 1000

618 normalize.schemas = false

619 propagate.schema.tags = false

620 proxy.host =

621 proxy.port = -1

622 retries.max.wait.ms = 20000

623 retries.wait.ms = 1000

624 rule.actions = []

625 rule.executors = []

626 rule.service.loader.enable = true

627 schema.format = null

628 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

642 schema.registry.ssl.provider = null

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

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

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

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

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

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

649 schema.registry.url = []

650 schema.registry.url.randomize = false

651 specific.avro.key.type = null

652 specific.avro.reader = false

653 specific.avro.value.type = null

654 use.latest.version = false

655 use.latest.with.metadata = null

656 use.schema.id = -1

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

658

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

66022:17:49.323 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

661 auto.register.schemas = true

662 avro.reflection.allow.null = false

663 avro.remove.java.properties = false

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

665 basic.auth.credentials.source = URL

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

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

668 bearer.auth.client.id = null

669 bearer.auth.client.secret = null

670 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

674 bearer.auth.logical.cluster = null

675 bearer.auth.scope = null

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

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

678 bearer.auth.token = [hidden]

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

680 http.connect.timeout.ms = 60000

681 http.read.timeout.ms = 60000

682 id.compatibility.strict = true

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

684 latest.cache.size = 1000

685 latest.cache.ttl.sec = -1

686 latest.compatibility.strict = true

687 max.retries = 3

688 max.schemas.per.subject = 1000

689 normalize.schemas = false

690 propagate.schema.tags = false

691 proxy.host =

692 proxy.port = -1

693 retries.max.wait.ms = 20000

694 retries.wait.ms = 1000

695 rule.actions = []

696 rule.executors = []

697 rule.service.loader.enable = true

698 schema.format = null

699 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

713 schema.registry.ssl.provider = null

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

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

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

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

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

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

720 schema.registry.url = []

721 schema.registry.url.randomize = false

722 use.latest.version = false

723 use.latest.with.metadata = null

724 use.schema.id = -1

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

726

72722:17:49.325 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

728 auto.register.schemas = true

729 avro.reflection.allow.null = false

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

731 basic.auth.credentials.source = URL

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

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

734 bearer.auth.client.id = null

735 bearer.auth.client.secret = null

736 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

740 bearer.auth.logical.cluster = null

741 bearer.auth.scope = null

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

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

744 bearer.auth.token = [hidden]

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

746 http.connect.timeout.ms = 60000

747 http.read.timeout.ms = 60000

748 id.compatibility.strict = true

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

750 latest.cache.size = 1000

751 latest.cache.ttl.sec = -1

752 latest.compatibility.strict = true

753 max.retries = 3

754 max.schemas.per.subject = 1000

755 normalize.schemas = false

756 propagate.schema.tags = false

757 proxy.host =

758 proxy.port = -1

759 retries.max.wait.ms = 20000

760 retries.wait.ms = 1000

761 rule.actions = []

762 rule.executors = []

763 rule.service.loader.enable = true

764 schema.format = null

765 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

779 schema.registry.ssl.provider = null

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

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

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

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

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

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

786 schema.registry.url = []

787 schema.registry.url.randomize = false

788 specific.avro.key.type = null

789 specific.avro.reader = false

790 specific.avro.value.type = null

791 use.latest.version = false

792 use.latest.with.metadata = null

793 use.schema.id = -1

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

795

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

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

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

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

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

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

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

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

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

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

809[info] AvroSerializerSpec:

810[info] AvroSerializer

81122:17:49.513 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

812 auto.register.schemas = true

813 avro.reflection.allow.null = false

814 avro.remove.java.properties = false

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

816 basic.auth.credentials.source = URL

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

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

819 bearer.auth.client.id = null

820 bearer.auth.client.secret = null

821 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

825 bearer.auth.logical.cluster = null

826 bearer.auth.scope = null

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

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

829 bearer.auth.token = [hidden]

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

831 http.connect.timeout.ms = 60000

832 http.read.timeout.ms = 60000

833 id.compatibility.strict = true

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

835 latest.cache.size = 1000

836 latest.cache.ttl.sec = -1

837 latest.compatibility.strict = true

838 max.retries = 3

839 max.schemas.per.subject = 1000

840 normalize.schemas = false

841 propagate.schema.tags = false

842 proxy.host =

843 proxy.port = -1

844 retries.max.wait.ms = 20000

845 retries.wait.ms = 1000

846 rule.actions = []

847 rule.executors = []

848 rule.service.loader.enable = true

849 schema.format = null

850 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

864 schema.registry.ssl.provider = null

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

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

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

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

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

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

871 schema.registry.url = []

872 schema.registry.url.randomize = false

873 use.latest.version = false

874 use.latest.with.metadata = null

875 use.schema.id = -1

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

877

87822:17:49.516 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

879 auto.register.schemas = true

880 avro.reflection.allow.null = false

881 avro.remove.java.properties = false

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

883 basic.auth.credentials.source = URL

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

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

886 bearer.auth.client.id = null

887 bearer.auth.client.secret = null

888 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

892 bearer.auth.logical.cluster = null

893 bearer.auth.scope = null

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

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

896 bearer.auth.token = [hidden]

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

898 http.connect.timeout.ms = 60000

899 http.read.timeout.ms = 60000

900 id.compatibility.strict = true

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

902 latest.cache.size = 1000

903 latest.cache.ttl.sec = -1

904 latest.compatibility.strict = true

905 max.retries = 3

906 max.schemas.per.subject = 1000

907 normalize.schemas = false

908 propagate.schema.tags = false

909 proxy.host =

910 proxy.port = -1

911 retries.max.wait.ms = 20000

912 retries.wait.ms = 1000

913 rule.actions = []

914 rule.executors = []

915 rule.service.loader.enable = true

916 schema.format = null

917 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

931 schema.registry.ssl.provider = null

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

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

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

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

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

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

938 schema.registry.url = []

939 schema.registry.url.randomize = false

940 use.latest.version = false

941 use.latest.with.metadata = null

942 use.schema.id = -1

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

944

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

94622:17:49.520 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

947 auto.register.schemas = true

948 avro.reflection.allow.null = false

949 avro.remove.java.properties = false

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

951 basic.auth.credentials.source = URL

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

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

954 bearer.auth.client.id = null

955 bearer.auth.client.secret = null

956 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

960 bearer.auth.logical.cluster = null

961 bearer.auth.scope = null

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

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

964 bearer.auth.token = [hidden]

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

966 http.connect.timeout.ms = 60000

967 http.read.timeout.ms = 60000

968 id.compatibility.strict = true

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

970 latest.cache.size = 1000

971 latest.cache.ttl.sec = -1

972 latest.compatibility.strict = true

973 max.retries = 3

974 max.schemas.per.subject = 1000

975 normalize.schemas = false

976 propagate.schema.tags = false

977 proxy.host =

978 proxy.port = -1

979 retries.max.wait.ms = 20000

980 retries.wait.ms = 1000

981 rule.actions = []

982 rule.executors = []

983 rule.service.loader.enable = true

984 schema.format = null

985 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

999 schema.registry.ssl.provider = null

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

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

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

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

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

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

1006 schema.registry.url = []

1007 schema.registry.url.randomize = false

1008 use.latest.version = false

1009 use.latest.with.metadata = null

1010 use.schema.id = -1

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

1012

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

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

1015[info] - toString (1 millisecond)

1016[info] AuthSpec:

1017[info] Auth.Basic

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

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

1020[info] Auth.Bearer

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

1022[info] Auth.None

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

1024[info] SchemaRegistryClientSettingsSpec:

1025[info] SchemaRegistryClientSettings

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

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

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

1029[info] - should provide withAuth(Auth.None) (0 milliseconds)

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

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

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

1033[info] - should provide withCreateSchemaRegistryClient (1 millisecond)

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

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

1036[info] AvroDeserializerSpec:

1037[info] AvroDeserializer

103822:17:49.602 [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

1106

110722:17:49.604 [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

1175

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

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

117822:17:49.611 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

1179 auto.register.schemas = true

1180 avro.reflection.allow.null = false

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

1182 basic.auth.credentials.source = URL

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

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

1185 bearer.auth.client.id = null

1186 bearer.auth.client.secret = null

1187 bearer.auth.credentials.source = STATIC_TOKEN

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

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

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

1191 bearer.auth.logical.cluster = null

1192 bearer.auth.scope = null

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

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

1195 bearer.auth.token = [hidden]

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

1197 http.connect.timeout.ms = 60000

1198 http.read.timeout.ms = 60000

1199 id.compatibility.strict = true

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

1201 latest.cache.size = 1000

1202 latest.cache.ttl.sec = -1

1203 latest.compatibility.strict = true

1204 max.retries = 3

1205 max.schemas.per.subject = 1000

1206 normalize.schemas = false

1207 propagate.schema.tags = false

1208 proxy.host =

1209 proxy.port = -1

1210 retries.max.wait.ms = 20000

1211 retries.wait.ms = 1000

1212 rule.actions = []

1213 rule.executors = []

1214 rule.service.loader.enable = true

1215 schema.format = null

1216 schema.reflection = false

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

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

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

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

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

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

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

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

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

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

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

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

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

1230 schema.registry.ssl.provider = null

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

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

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

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

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

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

1237 schema.registry.url = []

1238 schema.registry.url.randomize = false

1239 specific.avro.key.type = null

1240 specific.avro.reader = false

1241 specific.avro.value.type = null

1242 use.latest.version = false

1243 use.latest.with.metadata = null

1244 use.schema.id = -1

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

1246

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

1248[info] - toString (1 millisecond)

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

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

1251[info] compiling 1 Scala source to /build/repo/modules/vulcan-testkit-munit/target/scala-3.8.0-RC5/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-RC5/test-classes ...

1256[info] done compiling

1257[info] TimestampLawsSpec:

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

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

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

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

1262[info] UnexpectedTopicExceptionSpec:

1263[info] UnexpectedTopicException

1264[info] - should have expected message and toString (8 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 (264 milliseconds)

1271[info] Jitter#none

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

1273[info] SerializationExceptionSpec:

1274[info] SerializationException

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

1276[info] ConsumerRecordLawsSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1337[info] CommitTimeoutExceptionSpec:

1338[info] CommitTimeoutException

1339[info] - should have expected message and toString (17 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 (7 milliseconds)

1346[info] Timeout#logAppendTime

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

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

1351[info] Timeout#unknownTime

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

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

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

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

1365[info] KafkaSpec:

1366[info] commitBatchWithin

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

1368[info] ProducerRecordLawsSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1391[info] - ProducerRecord.traverseLaws.traverse.forall is lazy (1 millisecond)

1392[info] - ProducerRecord.traverseLaws.traverse.forall true if empty (1 millisecond)

1393[info] - ProducerRecord.traverseLaws.traverse.get reference (3 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 (1 millisecond)

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

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

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

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

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

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

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

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

1405[info] - ProducerRecord.traverseLaws.traverse.traverse order consistency (1 millisecond)

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

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

1410[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (2 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 (4 milliseconds)

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

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

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

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

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

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

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

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

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

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

1424[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (6 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 (3 milliseconds)

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

1429[info] AutoOffsetResetSpec:

1430[info] AutoOffsetReset

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

1432[info] ConsumerSettingsSpec:

1433[info] ConsumerSettings

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

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

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

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

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

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

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

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

1447[info] - should provide withAutoCommitInterval (1 millisecond)

1448[info] - should provide withRequestTimeout (1 millisecond)

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

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

1454[info] - should provide withCommitTimeout (1 millisecond)

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

1456[info] - should provide withPollTimeout (1 millisecond)

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

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

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

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

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

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

1463[info] ConsumerShutdownExceptionSpec:

1464[info] ConsumerShutdownException

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

1466[info] HeaderSerializerSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1484[info] - HeaderSerializer#short (3 milliseconds)

1485[info] HeadersLawsSpec:

1486[info] - Headers.eqLaws.eq.antisymmetry eq (5 milliseconds)

1487[info] - Headers.eqLaws.eq.reflexivity eq (3 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 (1 millisecond)

1493[info] - should return updated offset as batch (4 milliseconds)

1494[info] CommittableOffsetBatch#updated

1495[info] - should include the provided offset (8 milliseconds)

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

1497[info] - should be able to update with batch (9 milliseconds)

1498[info] CommittableOffsetBatch#toString

1499[info] - should provide a Show instance and matching toString (3 milliseconds)

1500[info] ProducerSettingsSpec:

1501[info] ProducerSettings

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

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

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

1508[info] - should provide withMaxInFlightRequestsPerConnection (0 milliseconds)

1509[info] - should provide withEnableIdempotence (0 milliseconds)

1510[info] - should provide withLinger (0 milliseconds)

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

1512[info] - should provide withDeliveryTimeout (0 milliseconds)

1513[info] - should provide withProperty/withProperties (1 millisecond)

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

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

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

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

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

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

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

1521[info] ConsumerRecordSpec:

1522[info] ConsumerRecord#fromJava

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

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

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

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

1527[info] ConsumerRecord#toString

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

1529[info] - should include timestamp if present (0 milliseconds)

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

1531[info] - should include serialized value size if present (0 milliseconds)

1532[info] - should include leader epoch if present (0 milliseconds)

1533[info] AcksSpec:

1534[info] Acks

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

1536[info] CommitRecoverySpec:

1537[info] CommitRecovery#Default

1538[info] - should retry org.apache.kafka.clients.consumer.RetriableCommitFailedException: retriable with jittered exponential backoff and fixed rate (16 milliseconds)

1539[info] - should retry org.apache.kafka.common.errors.RebalanceInProgressException with jittered exponential backoff and fixed rate (2 milliseconds)

1540[info] - should not recover non-retriable exceptions (1 millisecond)

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

1542[info] CommitRecovery#None

1543[info] - should not recover any exceptions (2 milliseconds)

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

1545[info] CommittableOffsetLawsSpec:

1546[info] - CommittableOffset.eqLaws.eq.antisymmetry eq (3 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 (2 milliseconds)

1550[info] CommittableProducerRecordsLawsSpec:

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

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

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

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

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

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

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

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

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

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

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

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

1563[info] - CommittableProducerRecord.traverseLaws.traverse.exists consistent with find (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 (4 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1586[info] - CommittableProducerRecord.traverseLaws.traverse.traverse identity (7 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 (7 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1611[info] HeaderDeserializerSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1643[info] - HeaderDeserializer#unit (2 milliseconds)

1644[info] - HeaderDeserializer#toString (1 millisecond)

1645[info] CommittableConsumerRecordLawsSpec:

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

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

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

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

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

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

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

1653[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with exists (4 milliseconds)

1654[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with forall (3 milliseconds)

1655[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant composition (3 milliseconds)

1656[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant identity (2 milliseconds)

1657[info] - CommittableConsumerRecord.traverseLaws.traverse.dropWhile_ reference (1 millisecond)

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

1659[info] - CommittableConsumerRecord.traverseLaws.traverse.exists is lazy (2 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 (2 milliseconds)

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

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

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

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

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

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

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

1671[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant composition (4 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 (1 millisecond)

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

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

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

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

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

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

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

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

1683[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse parallel composition (2 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 (2 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1706[info] DeserializationExceptionSpec:

1707[info] DeserializationException

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

1709[info] HeaderSpec:

1710[info] Header

1711[info] - toString should be Header(key -> value) (0 milliseconds)

1712[info] - should have consistent toString and Show (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 (0 milliseconds)

1717[info] HeaderLawsSpec:

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

1719[info] - Header.eqLaws.eq.reflexivity eq (1 millisecond)

1720[info] - Header.eqLaws.eq.symmetry eq (1 millisecond)

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

1722[info] SerializerSpec:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1742[info] - Serializer#toString (1 millisecond)

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

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

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

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

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

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

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

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

1751[info] DeserializerSpec:

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

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

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

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

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

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

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

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

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

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

1762[info] - Deserializer[IO, *].monadError.applicativeError handle (122 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 (123 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1793[info] - Deserializer[IO, *].monadError.monadError left zero (67 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 (65 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

1815[info] - Deserializer#option (5 milliseconds)

1816[info] - Deserializer#unit (3 milliseconds)

1817[info] - Deserializer#toString (0 milliseconds)

1818[info] KafkaCredentialStoreSpec:

1819[info] KafkaCredentialStore

1820[info] fromPemStrings

1821[info] - should create a KafkaCredentialStore with the expected properties (1 millisecond)

1822[info] HeadersSpec:

1823[info] Headers#empty

1824[info] - should have toString as Headers() (0 milliseconds)

1825[info] - should return true for isEmpty (1 millisecond)

1826[info] - should return false for nonEmpty (0 milliseconds)

1827[info] - should return false for exists (0 milliseconds)

1828[info] - should not find any key (0 milliseconds)

1829[info] - should concat empty (1 millisecond)

1830[info] - should concat non-empty (1 millisecond)

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

1835[info] - add(header) throws IllegalStateException (1 millisecond)

1836[info] - add(key, value) throws IllegalStateException (1 millisecond)

1837[info] - remove throws IllegalStateException (1 millisecond)

1838[info] - lastHeader returns null (1 millisecond)

1839[info] - headers returns empty iterable (1 millisecond)

1840[info] - toArray returns empty array (0 milliseconds)

1841[info] - iterator.next throws NoSuchElementException (1 millisecond)

1842[info] - iterator.hasNext returns false (0 milliseconds)

1843[info] Headers#nonEmpty.asJava

1844[info] - add(header) throws IllegalStateException (0 milliseconds)

1845[info] - add(key, value) throws IllegalStateException (1 millisecond)

1846[info] - remove throws IllegalStateException (0 milliseconds)

1847[info] - lastHeader returns last header (1 millisecond)

1848[info] - lastHeaders returns existing header (0 milliseconds)

1849[info] - lastHeader returns null for missing key (0 milliseconds)

1850[info] - headers returns matching headers (4 milliseconds)

1851[info] - headers returns empty if no matching headers (0 milliseconds)

1852[info] - toArray returns elements (0 milliseconds)

1853[info] - iterator returns elements (0 milliseconds)

1854[info] Headers#nonEmpty

1855[info] - should not be empty (0 milliseconds)

1856[info] - should be non empty (0 milliseconds)

1857[info] - should find an existing key (0 milliseconds)

1858[info] - should find the first key (1 millisecond)

1859[info] - should return true for existing key (1 millisecond)

1860[info] - should return false for non-existing key (1 millisecond)

1861[info] - should concat empty (0 milliseconds)

1862[info] - should concat non-empty (0 milliseconds)

1863[info] - should include the headers in toString (1 millisecond)

1864[info] - should append one more header with append(Header) (0 milliseconds)

1865[info] - should append one more header with append(key, value) (0 milliseconds)

1866[info] Headers#apply

1867[info] - returns empty for no headers (0 milliseconds)

1868[info] - returns non-empty for at least one header (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 (6 milliseconds)

1881[info] KafkaHeaders#asScala

1882[info] - should convert empty (1 millisecond)

1883[info] - should convert non-empty (0 milliseconds)

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-RC5

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-RC5"

1903"++3.8.0-RC5 -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-RC5 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}""" com.github.fd4s%fs2-kafka com.github.fd4s%fs2-kafka-vulcan com.github.fd4s%fs2-kafka-vulcan-testkit-munit"

1911

1912[info] welcome to sbt 1.11.7 (Eclipse Adoptium Java 21)

1913[info] loading settings for project repo-build from akka.sbt, plugins.sbt...

1914[info] loading project definition from /build/repo/project

1915[info] loading settings for project fs2-kafka from build.sbt...

1916[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1917[info] set current project to fs2-kafka (in build file:/build/repo/)

1918Execute setCrossScalaVersions: 3.8.0-RC5

1919[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1920OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in vulcan-testkit-munit/crossScalaVersions

1921OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in vulcan/crossScalaVersions

1922OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in core/crossScalaVersions

1923OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 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-RC5 on 4 projects.

1926[info] Switching Scala version on:

1927[info] * fs2-kafka (2.12.20, 2.13.17, 3.8.0-RC5)

1928[info] vulcan-testkit-munit (2.12.20, 2.13.17, 3.8.0-RC5)

1929[info] core (2.12.20, 2.13.17, 3.8.0-RC5)

1930[info] vulcan (2.12.20, 2.13.17, 3.8.0-RC5)

1931[info] Excluding projects:

1932[info] docs (2.13.17)

1933[info] Reapplying settings...

1934[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1935[info] set current project to fs2-kafka (in build file:/build/repo/)

1936Execute mapScalacOptions: ,REQUIRE:-source:3.8,-Wconf:msg=can be rewritten automatically under:s ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

1937[info] Reapplying settings...

1938[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1939[info] set current project to fs2-kafka (in build file:/build/repo/)

1940[info] Defining Global / credentials, core / credentials and 3 others.

1941[info] The new values will be used by Compile / scalafmtOnly, IntegrationTest / scalafmtOnly and 42 others.

1942[info] Run `last` for details.

1943[info] Reapplying settings...

1944[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1945[info] set current project to fs2-kafka (in build file:/build/repo/)

1946Execute excludeLibraryDependency: com.github.ghik:zerowaste_{scalaVersion} com.olegpy:better-monadic-for_3 org.polyvariant:better-tostring_{scalaVersion} org.wartremover:wartremover_{scalaVersion}

1947[info] Reapplying settings...

1948OpenCB::Failed to reapply settings in excludeLibraryDependency: Reference to undefined setting:

1949

1950 Global / allExcludeDependencies from Global / allExcludeDependencies (CommunityBuildPlugin.scala:331)

1951 Did you mean allExcludeDependencies ?

1952 , retry without global scopes

1953[info] Reapplying settings...

1954[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1955[info] set current project to fs2-kafka (in build file:/build/repo/)

1956Execute removeScalacOptionsStartingWith: -P:wartremover

1957[info] Reapplying settings...

1958[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1959[info] set current project to fs2-kafka (in build file:/build/repo/)

1960[info] Defining core / Test / unmanagedSources / excludeFilter

1961[info] The new value will be used by core / Test / unmanagedSources / fileInputs

1962[info] Reapplying settings...

1963[info] set scmInfo to https://github.com/fd4s/fs2-kafka

1964[info] set current project to fs2-kafka (in build file:/build/repo/)

1965[success] Total time: 0 s, completed Jan 1, 2026, 12:07:14 AM

1966Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":["set core/Test/unmanagedSources/excludeFilter ~= {_ || \"KafkaProducerConnectionSpec.scala\" || \"KafkaConsumerSpec.scala\" || \"KafkaProducerSpec.scala\" || \"TransactionalKafkaProducerSpec.scala\" || \"TransactionalKafkaProducerTimeoutSpec.scala\" || \"KafkaAdminClientSpec.scala\"} "],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[{"path":"build.sbt","pattern":"val scala3 = \"3.3.6\"","replaceWith":"val scala3 = \"<SCALA_VERSION>\""}]}

1967Parsed config: Success(ProjectBuildConfig(ProjectsConfig(List(),Map()),Full,List()))

1968Starting build...

1969Projects: Set(fs2-kafka, vulcan, vulcan-testkit-munit, core)

1970Starting build for ProjectRef(file:/build/repo/,fs2-kafka) (fs2-kafka)... [0/4]

1971OpenCB::Exclude Scala3 specific scalacOption `REQUIRE:-source:3.8` in Scala 2.12.20 module Global

1972OpenCB::Filter out '-deprecation', matches setting pattern '^-?-deprecation'

1973OpenCB::Filter out '-feature', matches setting pattern '^-?-feature'

1974Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

1975Starting build for ProjectRef(file:/build/repo/,vulcan) (fs2-kafka-vulcan)... [1/4]

1976Compile scalacOptions: -encoding, UTF-8, -unchecked, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wvalue-discard, -language:implicitConversions, -Xkind-projector, --java-output-version:17, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

1977[info] PackageSpec:

1978[info] avroSerializer

1979[info] - should be available given explicit settings (355 milliseconds)

1980[info] avroDeserializer

1981[info] - should be available given explicit settings (3 milliseconds)

1982[info] avroSerializer/avroDeserializer

198300:07:20.387 [io-compute-3] 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

2049

205000:07:20.387 [io-compute-0] 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

2118

2119[info] - should be able to do roundtrip serialization (344 milliseconds)

212000:07:20.488 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2121 auto.register.schemas = true

2122 avro.reflection.allow.null = false

2123 avro.use.logical.type.converters = false

2124 basic.auth.credentials.source = URL

2125 basic.auth.user.info = [hidden]

2126 bearer.auth.cache.expiry.buffer.seconds = 300

2127 bearer.auth.client.id = null

2128 bearer.auth.client.secret = null

2129 bearer.auth.credentials.source = STATIC_TOKEN

2130 bearer.auth.custom.provider.class = null

2131 bearer.auth.identity.pool.id = null

2132 bearer.auth.issuer.endpoint.url = null

2133 bearer.auth.logical.cluster = null

2134 bearer.auth.scope = null

2135 bearer.auth.scope.claim.name = scope

2136 bearer.auth.sub.claim.name = sub

2137 bearer.auth.token = [hidden]

2138 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2139 http.connect.timeout.ms = 60000

2140 http.read.timeout.ms = 60000

2141 id.compatibility.strict = true

2142 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2143 latest.cache.size = 1000

2144 latest.cache.ttl.sec = -1

2145 latest.compatibility.strict = true

2146 max.retries = 3

2147 max.schemas.per.subject = 1000

2148 normalize.schemas = false

2149 propagate.schema.tags = false

2150 proxy.host =

2151 proxy.port = -1

2152 retries.max.wait.ms = 20000

2153 retries.wait.ms = 1000

2154 rule.actions = []

2155 rule.executors = []

2156 rule.service.loader.enable = true

2157 schema.format = null

2158 schema.reflection = false

2159 schema.registry.basic.auth.user.info = [hidden]

2160 schema.registry.ssl.cipher.suites = null

2161 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2162 schema.registry.ssl.endpoint.identification.algorithm = https

2163 schema.registry.ssl.engine.factory.class = null

2164 schema.registry.ssl.key.password = null

2165 schema.registry.ssl.keymanager.algorithm = SunX509

2166 schema.registry.ssl.keystore.certificate.chain = null

2167 schema.registry.ssl.keystore.key = null

2168 schema.registry.ssl.keystore.location = null

2169 schema.registry.ssl.keystore.password = null

2170 schema.registry.ssl.keystore.type = JKS

2171 schema.registry.ssl.protocol = TLSv1.3

2172 schema.registry.ssl.provider = null

2173 schema.registry.ssl.secure.random.implementation = null

2174 schema.registry.ssl.trustmanager.algorithm = PKIX

2175 schema.registry.ssl.truststore.certificates = null

2176 schema.registry.ssl.truststore.location = null

2177 schema.registry.ssl.truststore.password = null

2178 schema.registry.ssl.truststore.type = JKS

2179 schema.registry.url = []

2180 schema.registry.url.randomize = false

2181 specific.avro.key.type = null

2182 specific.avro.reader = false

2183 specific.avro.value.type = null

2184 use.latest.version = false

2185 use.latest.with.metadata = null

2186 use.schema.id = -1

2187 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2188

218900:07:20.492 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2190 auto.register.schemas = true

2191 avro.reflection.allow.null = false

2192 avro.remove.java.properties = false

2193 avro.use.logical.type.converters = false

2194 basic.auth.credentials.source = URL

2195 basic.auth.user.info = [hidden]

2196 bearer.auth.cache.expiry.buffer.seconds = 300

2197 bearer.auth.client.id = null

2198 bearer.auth.client.secret = null

2199 bearer.auth.credentials.source = STATIC_TOKEN

2200 bearer.auth.custom.provider.class = null

2201 bearer.auth.identity.pool.id = null

2202 bearer.auth.issuer.endpoint.url = null

2203 bearer.auth.logical.cluster = null

2204 bearer.auth.scope = null

2205 bearer.auth.scope.claim.name = scope

2206 bearer.auth.sub.claim.name = sub

2207 bearer.auth.token = [hidden]

2208 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2209 http.connect.timeout.ms = 60000

2210 http.read.timeout.ms = 60000

2211 id.compatibility.strict = true

2212 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2213 latest.cache.size = 1000

2214 latest.cache.ttl.sec = -1

2215 latest.compatibility.strict = true

2216 max.retries = 3

2217 max.schemas.per.subject = 1000

2218 normalize.schemas = false

2219 propagate.schema.tags = false

2220 proxy.host =

2221 proxy.port = -1

2222 retries.max.wait.ms = 20000

2223 retries.wait.ms = 1000

2224 rule.actions = []

2225 rule.executors = []

2226 rule.service.loader.enable = true

2227 schema.format = null

2228 schema.reflection = false

2229 schema.registry.basic.auth.user.info = [hidden]

2230 schema.registry.ssl.cipher.suites = null

2231 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2232 schema.registry.ssl.endpoint.identification.algorithm = https

2233 schema.registry.ssl.engine.factory.class = null

2234 schema.registry.ssl.key.password = null

2235 schema.registry.ssl.keymanager.algorithm = SunX509

2236 schema.registry.ssl.keystore.certificate.chain = null

2237 schema.registry.ssl.keystore.key = null

2238 schema.registry.ssl.keystore.location = null

2239 schema.registry.ssl.keystore.password = null

2240 schema.registry.ssl.keystore.type = JKS

2241 schema.registry.ssl.protocol = TLSv1.3

2242 schema.registry.ssl.provider = null

2243 schema.registry.ssl.secure.random.implementation = null

2244 schema.registry.ssl.trustmanager.algorithm = PKIX

2245 schema.registry.ssl.truststore.certificates = null

2246 schema.registry.ssl.truststore.location = null

2247 schema.registry.ssl.truststore.password = null

2248 schema.registry.ssl.truststore.type = JKS

2249 schema.registry.url = []

2250 schema.registry.url.randomize = false

2251 use.latest.version = false

2252 use.latest.with.metadata = null

2253 use.schema.id = -1

2254 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2255

2256[info] - should be able to do roundtrip serialization using compatible schemas (35 milliseconds)

225700:07:20.523 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2258 auto.register.schemas = true

2259 avro.reflection.allow.null = false

2260 avro.use.logical.type.converters = false

2261 basic.auth.credentials.source = URL

2262 basic.auth.user.info = [hidden]

2263 bearer.auth.cache.expiry.buffer.seconds = 300

2264 bearer.auth.client.id = null

2265 bearer.auth.client.secret = null

2266 bearer.auth.credentials.source = STATIC_TOKEN

2267 bearer.auth.custom.provider.class = null

2268 bearer.auth.identity.pool.id = null

2269 bearer.auth.issuer.endpoint.url = null

2270 bearer.auth.logical.cluster = null

2271 bearer.auth.scope = null

2272 bearer.auth.scope.claim.name = scope

2273 bearer.auth.sub.claim.name = sub

2274 bearer.auth.token = [hidden]

2275 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2276 http.connect.timeout.ms = 60000

2277 http.read.timeout.ms = 60000

2278 id.compatibility.strict = true

2279 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2280 latest.cache.size = 1000

2281 latest.cache.ttl.sec = -1

2282 latest.compatibility.strict = true

2283 max.retries = 3

2284 max.schemas.per.subject = 1000

2285 normalize.schemas = false

2286 propagate.schema.tags = false

2287 proxy.host =

2288 proxy.port = -1

2289 retries.max.wait.ms = 20000

2290 retries.wait.ms = 1000

2291 rule.actions = []

2292 rule.executors = []

2293 rule.service.loader.enable = true

2294 schema.format = null

2295 schema.reflection = false

2296 schema.registry.basic.auth.user.info = [hidden]

2297 schema.registry.ssl.cipher.suites = null

2298 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2299 schema.registry.ssl.endpoint.identification.algorithm = https

2300 schema.registry.ssl.engine.factory.class = null

2301 schema.registry.ssl.key.password = null

2302 schema.registry.ssl.keymanager.algorithm = SunX509

2303 schema.registry.ssl.keystore.certificate.chain = null

2304 schema.registry.ssl.keystore.key = null

2305 schema.registry.ssl.keystore.location = null

2306 schema.registry.ssl.keystore.password = null

2307 schema.registry.ssl.keystore.type = JKS

2308 schema.registry.ssl.protocol = TLSv1.3

2309 schema.registry.ssl.provider = null

2310 schema.registry.ssl.secure.random.implementation = null

2311 schema.registry.ssl.trustmanager.algorithm = PKIX

2312 schema.registry.ssl.truststore.certificates = null

2313 schema.registry.ssl.truststore.location = null

2314 schema.registry.ssl.truststore.password = null

2315 schema.registry.ssl.truststore.type = JKS

2316 schema.registry.url = []

2317 schema.registry.url.randomize = false

2318 specific.avro.key.type = null

2319 specific.avro.reader = false

2320 specific.avro.value.type = null

2321 use.latest.version = false

2322 use.latest.with.metadata = null

2323 use.schema.id = -1

2324 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2325

232600:07:20.523 [io-compute-1] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2327 auto.register.schemas = true

2328 avro.reflection.allow.null = false

2329 avro.remove.java.properties = false

2330 avro.use.logical.type.converters = false

2331 basic.auth.credentials.source = URL

2332 basic.auth.user.info = [hidden]

2333 bearer.auth.cache.expiry.buffer.seconds = 300

2334 bearer.auth.client.id = null

2335 bearer.auth.client.secret = null

2336 bearer.auth.credentials.source = STATIC_TOKEN

2337 bearer.auth.custom.provider.class = null

2338 bearer.auth.identity.pool.id = null

2339 bearer.auth.issuer.endpoint.url = null

2340 bearer.auth.logical.cluster = null

2341 bearer.auth.scope = null

2342 bearer.auth.scope.claim.name = scope

2343 bearer.auth.sub.claim.name = sub

2344 bearer.auth.token = [hidden]

2345 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2346 http.connect.timeout.ms = 60000

2347 http.read.timeout.ms = 60000

2348 id.compatibility.strict = true

2349 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2350 latest.cache.size = 1000

2351 latest.cache.ttl.sec = -1

2352 latest.compatibility.strict = true

2353 max.retries = 3

2354 max.schemas.per.subject = 1000

2355 normalize.schemas = false

2356 propagate.schema.tags = false

2357 proxy.host =

2358 proxy.port = -1

2359 retries.max.wait.ms = 20000

2360 retries.wait.ms = 1000

2361 rule.actions = []

2362 rule.executors = []

2363 rule.service.loader.enable = true

2364 schema.format = null

2365 schema.reflection = false

2366 schema.registry.basic.auth.user.info = [hidden]

2367 schema.registry.ssl.cipher.suites = null

2368 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2369 schema.registry.ssl.endpoint.identification.algorithm = https

2370 schema.registry.ssl.engine.factory.class = null

2371 schema.registry.ssl.key.password = null

2372 schema.registry.ssl.keymanager.algorithm = SunX509

2373 schema.registry.ssl.keystore.certificate.chain = null

2374 schema.registry.ssl.keystore.key = null

2375 schema.registry.ssl.keystore.location = null

2376 schema.registry.ssl.keystore.password = null

2377 schema.registry.ssl.keystore.type = JKS

2378 schema.registry.ssl.protocol = TLSv1.3

2379 schema.registry.ssl.provider = null

2380 schema.registry.ssl.secure.random.implementation = null

2381 schema.registry.ssl.trustmanager.algorithm = PKIX

2382 schema.registry.ssl.truststore.certificates = null

2383 schema.registry.ssl.truststore.location = null

2384 schema.registry.ssl.truststore.password = null

2385 schema.registry.ssl.truststore.type = JKS

2386 schema.registry.url = []

2387 schema.registry.url.randomize = false

2388 use.latest.version = false

2389 use.latest.with.metadata = null

2390 use.schema.id = -1

2391 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2392

2393[info] - should error when reader and writer schemas have mismatching logical types (16 milliseconds)

2394[info] AvroSettingsSpec:

2395[info] AvroSettings

2396[info] - should provide withAutoRegisterSchemas (97 milliseconds)

2397[info] - should provide withKeySubjectNameStrategy (6 milliseconds)

2398[info] - should provide withValueSubjectNameStrategy (4 milliseconds)

2399[info] - should provide withProperty (6 milliseconds)

2400[info] - should provide withProperties (4 milliseconds)

2401[info] - should provide withProperties(Map) (3 milliseconds)

2402[info] - should provide withCreateAvroDeserializer (1 millisecond)

2403[info] - should provide withCreateAvroSerializer (2 milliseconds)

2404[info] - should provide withRegisterSchema (1 millisecond)

2405[info] - should provide toString (1 millisecond)

2406[info] AvroSerializerSpec:

2407[info] AvroSerializer

240800:07:20.702 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2409 auto.register.schemas = true

2410 avro.reflection.allow.null = false

2411 avro.remove.java.properties = false

2412 avro.use.logical.type.converters = false

2413 basic.auth.credentials.source = URL

2414 basic.auth.user.info = [hidden]

2415 bearer.auth.cache.expiry.buffer.seconds = 300

2416 bearer.auth.client.id = null

2417 bearer.auth.client.secret = null

2418 bearer.auth.credentials.source = STATIC_TOKEN

2419 bearer.auth.custom.provider.class = null

2420 bearer.auth.identity.pool.id = null

2421 bearer.auth.issuer.endpoint.url = null

2422 bearer.auth.logical.cluster = null

2423 bearer.auth.scope = null

2424 bearer.auth.scope.claim.name = scope

2425 bearer.auth.sub.claim.name = sub

2426 bearer.auth.token = [hidden]

2427 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2428 http.connect.timeout.ms = 60000

2429 http.read.timeout.ms = 60000

2430 id.compatibility.strict = true

2431 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2432 latest.cache.size = 1000

2433 latest.cache.ttl.sec = -1

2434 latest.compatibility.strict = true

2435 max.retries = 3

2436 max.schemas.per.subject = 1000

2437 normalize.schemas = false

2438 propagate.schema.tags = false

2439 proxy.host =

2440 proxy.port = -1

2441 retries.max.wait.ms = 20000

2442 retries.wait.ms = 1000

2443 rule.actions = []

2444 rule.executors = []

2445 rule.service.loader.enable = true

2446 schema.format = null

2447 schema.reflection = false

2448 schema.registry.basic.auth.user.info = [hidden]

2449 schema.registry.ssl.cipher.suites = null

2450 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2451 schema.registry.ssl.endpoint.identification.algorithm = https

2452 schema.registry.ssl.engine.factory.class = null

2453 schema.registry.ssl.key.password = null

2454 schema.registry.ssl.keymanager.algorithm = SunX509

2455 schema.registry.ssl.keystore.certificate.chain = null

2456 schema.registry.ssl.keystore.key = null

2457 schema.registry.ssl.keystore.location = null

2458 schema.registry.ssl.keystore.password = null

2459 schema.registry.ssl.keystore.type = JKS

2460 schema.registry.ssl.protocol = TLSv1.3

2461 schema.registry.ssl.provider = null

2462 schema.registry.ssl.secure.random.implementation = null

2463 schema.registry.ssl.trustmanager.algorithm = PKIX

2464 schema.registry.ssl.truststore.certificates = null

2465 schema.registry.ssl.truststore.location = null

2466 schema.registry.ssl.truststore.password = null

2467 schema.registry.ssl.truststore.type = JKS

2468 schema.registry.url = []

2469 schema.registry.url.randomize = false

2470 use.latest.version = false

2471 use.latest.with.metadata = null

2472 use.schema.id = -1

2473 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2474

247500:07:20.705 [io-compute-3] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2476 auto.register.schemas = true

2477 avro.reflection.allow.null = false

2478 avro.remove.java.properties = false

2479 avro.use.logical.type.converters = false

2480 basic.auth.credentials.source = URL

2481 basic.auth.user.info = [hidden]

2482 bearer.auth.cache.expiry.buffer.seconds = 300

2483 bearer.auth.client.id = null

2484 bearer.auth.client.secret = null

2485 bearer.auth.credentials.source = STATIC_TOKEN

2486 bearer.auth.custom.provider.class = null

2487 bearer.auth.identity.pool.id = null

2488 bearer.auth.issuer.endpoint.url = null

2489 bearer.auth.logical.cluster = null

2490 bearer.auth.scope = null

2491 bearer.auth.scope.claim.name = scope

2492 bearer.auth.sub.claim.name = sub

2493 bearer.auth.token = [hidden]

2494 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2495 http.connect.timeout.ms = 60000

2496 http.read.timeout.ms = 60000

2497 id.compatibility.strict = true

2498 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2499 latest.cache.size = 1000

2500 latest.cache.ttl.sec = -1

2501 latest.compatibility.strict = true

2502 max.retries = 3

2503 max.schemas.per.subject = 1000

2504 normalize.schemas = false

2505 propagate.schema.tags = false

2506 proxy.host =

2507 proxy.port = -1

2508 retries.max.wait.ms = 20000

2509 retries.wait.ms = 1000

2510 rule.actions = []

2511 rule.executors = []

2512 rule.service.loader.enable = true

2513 schema.format = null

2514 schema.reflection = false

2515 schema.registry.basic.auth.user.info = [hidden]

2516 schema.registry.ssl.cipher.suites = null

2517 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2518 schema.registry.ssl.endpoint.identification.algorithm = https

2519 schema.registry.ssl.engine.factory.class = null

2520 schema.registry.ssl.key.password = null

2521 schema.registry.ssl.keymanager.algorithm = SunX509

2522 schema.registry.ssl.keystore.certificate.chain = null

2523 schema.registry.ssl.keystore.key = null

2524 schema.registry.ssl.keystore.location = null

2525 schema.registry.ssl.keystore.password = null

2526 schema.registry.ssl.keystore.type = JKS

2527 schema.registry.ssl.protocol = TLSv1.3

2528 schema.registry.ssl.provider = null

2529 schema.registry.ssl.secure.random.implementation = null

2530 schema.registry.ssl.trustmanager.algorithm = PKIX

2531 schema.registry.ssl.truststore.certificates = null

2532 schema.registry.ssl.truststore.location = null

2533 schema.registry.ssl.truststore.password = null

2534 schema.registry.ssl.truststore.type = JKS

2535 schema.registry.url = []

2536 schema.registry.url.randomize = false

2537 use.latest.version = false

2538 use.latest.with.metadata = null

2539 use.schema.id = -1

2540 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2541

2542[info] - can create a serializer (6 milliseconds)

254300:07:20.709 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig -- KafkaAvroSerializerConfig values:

2544 auto.register.schemas = true

2545 avro.reflection.allow.null = false

2546 avro.remove.java.properties = false

2547 avro.use.logical.type.converters = false

2548 basic.auth.credentials.source = URL

2549 basic.auth.user.info = [hidden]

2550 bearer.auth.cache.expiry.buffer.seconds = 300

2551 bearer.auth.client.id = null

2552 bearer.auth.client.secret = null

2553 bearer.auth.credentials.source = STATIC_TOKEN

2554 bearer.auth.custom.provider.class = null

2555 bearer.auth.identity.pool.id = null

2556 bearer.auth.issuer.endpoint.url = null

2557 bearer.auth.logical.cluster = null

2558 bearer.auth.scope = null

2559 bearer.auth.scope.claim.name = scope

2560 bearer.auth.sub.claim.name = sub

2561 bearer.auth.token = [hidden]

2562 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2563 http.connect.timeout.ms = 60000

2564 http.read.timeout.ms = 60000

2565 id.compatibility.strict = true

2566 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2567 latest.cache.size = 1000

2568 latest.cache.ttl.sec = -1

2569 latest.compatibility.strict = true

2570 max.retries = 3

2571 max.schemas.per.subject = 1000

2572 normalize.schemas = false

2573 propagate.schema.tags = false

2574 proxy.host =

2575 proxy.port = -1

2576 retries.max.wait.ms = 20000

2577 retries.wait.ms = 1000

2578 rule.actions = []

2579 rule.executors = []

2580 rule.service.loader.enable = true

2581 schema.format = null

2582 schema.reflection = false

2583 schema.registry.basic.auth.user.info = [hidden]

2584 schema.registry.ssl.cipher.suites = null

2585 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2586 schema.registry.ssl.endpoint.identification.algorithm = https

2587 schema.registry.ssl.engine.factory.class = null

2588 schema.registry.ssl.key.password = null

2589 schema.registry.ssl.keymanager.algorithm = SunX509

2590 schema.registry.ssl.keystore.certificate.chain = null

2591 schema.registry.ssl.keystore.key = null

2592 schema.registry.ssl.keystore.location = null

2593 schema.registry.ssl.keystore.password = null

2594 schema.registry.ssl.keystore.type = JKS

2595 schema.registry.ssl.protocol = TLSv1.3

2596 schema.registry.ssl.provider = null

2597 schema.registry.ssl.secure.random.implementation = null

2598 schema.registry.ssl.trustmanager.algorithm = PKIX

2599 schema.registry.ssl.truststore.certificates = null

2600 schema.registry.ssl.truststore.location = null

2601 schema.registry.ssl.truststore.password = null

2602 schema.registry.ssl.truststore.type = JKS

2603 schema.registry.url = []

2604 schema.registry.url.randomize = false

2605 use.latest.version = false

2606 use.latest.with.metadata = null

2607 use.schema.id = -1

2608 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2609

2610[info] - auto-registers union schemas (12 milliseconds)

2611[info] - raises schema errors (4 milliseconds)

2612[info] - toString (1 millisecond)

2613[info] AuthSpec:

2614[info] Auth.Basic

2615[info] - should include the username in toString (5 milliseconds)

2616[info] - should not include the password in toString (10 milliseconds)

2617[info] Auth.Bearer

2618[info] - should not include the token in toString (5 milliseconds)

2619[info] Auth.None

2620[info] - should have None as toString (1 millisecond)

2621[info] SchemaRegistryClientSettingsSpec:

2622[info] SchemaRegistryClientSettings

2623[info] - should provide withMaxCacheSize (0 milliseconds)

2624[info] - should provide withAuth(Auth.Basic) (5 milliseconds)

2625[info] - should provide withAuth(Auth.Bearer) (1 millisecond)

2626[info] - should provide withAuth(Auth.None) (0 milliseconds)

2627[info] - should provide withProperty (4 milliseconds)

2628[info] - should provide withProperties (2 milliseconds)

2629[info] - should provide withProperties(Map) (2 milliseconds)

2630[info] - should provide withCreateSchemaRegistryClient (1 millisecond)

2631[info] - should provide toString (3 milliseconds)

2632[info] - should provide Show (1 millisecond)

2633[info] AvroDeserializerSpec:

2634[info] AvroDeserializer

263500:07:20.815 [io-compute-2] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2636 auto.register.schemas = true

2637 avro.reflection.allow.null = false

2638 avro.use.logical.type.converters = false

2639 basic.auth.credentials.source = URL

2640 basic.auth.user.info = [hidden]

2641 bearer.auth.cache.expiry.buffer.seconds = 300

2642 bearer.auth.client.id = null

2643 bearer.auth.client.secret = null

2644 bearer.auth.credentials.source = STATIC_TOKEN

2645 bearer.auth.custom.provider.class = null

2646 bearer.auth.identity.pool.id = null

2647 bearer.auth.issuer.endpoint.url = null

2648 bearer.auth.logical.cluster = null

2649 bearer.auth.scope = null

2650 bearer.auth.scope.claim.name = scope

2651 bearer.auth.sub.claim.name = sub

2652 bearer.auth.token = [hidden]

2653 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2654 http.connect.timeout.ms = 60000

2655 http.read.timeout.ms = 60000

2656 id.compatibility.strict = true

2657 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2658 latest.cache.size = 1000

2659 latest.cache.ttl.sec = -1

2660 latest.compatibility.strict = true

2661 max.retries = 3

2662 max.schemas.per.subject = 1000

2663 normalize.schemas = false

2664 propagate.schema.tags = false

2665 proxy.host =

2666 proxy.port = -1

2667 retries.max.wait.ms = 20000

2668 retries.wait.ms = 1000

2669 rule.actions = []

2670 rule.executors = []

2671 rule.service.loader.enable = true

2672 schema.format = null

2673 schema.reflection = false

2674 schema.registry.basic.auth.user.info = [hidden]

2675 schema.registry.ssl.cipher.suites = null

2676 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2677 schema.registry.ssl.endpoint.identification.algorithm = https

2678 schema.registry.ssl.engine.factory.class = null

2679 schema.registry.ssl.key.password = null

2680 schema.registry.ssl.keymanager.algorithm = SunX509

2681 schema.registry.ssl.keystore.certificate.chain = null

2682 schema.registry.ssl.keystore.key = null

2683 schema.registry.ssl.keystore.location = null

2684 schema.registry.ssl.keystore.password = null

2685 schema.registry.ssl.keystore.type = JKS

2686 schema.registry.ssl.protocol = TLSv1.3

2687 schema.registry.ssl.provider = null

2688 schema.registry.ssl.secure.random.implementation = null

2689 schema.registry.ssl.trustmanager.algorithm = PKIX

2690 schema.registry.ssl.truststore.certificates = null

2691 schema.registry.ssl.truststore.location = null

2692 schema.registry.ssl.truststore.password = null

2693 schema.registry.ssl.truststore.type = JKS

2694 schema.registry.url = []

2695 schema.registry.url.randomize = false

2696 specific.avro.key.type = null

2697 specific.avro.reader = false

2698 specific.avro.value.type = null

2699 use.latest.version = false

2700 use.latest.with.metadata = null

2701 use.schema.id = -1

2702 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2703

270400:07:20.820 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2705 auto.register.schemas = true

2706 avro.reflection.allow.null = false

2707 avro.use.logical.type.converters = false

2708 basic.auth.credentials.source = URL

2709 basic.auth.user.info = [hidden]

2710 bearer.auth.cache.expiry.buffer.seconds = 300

2711 bearer.auth.client.id = null

2712 bearer.auth.client.secret = null

2713 bearer.auth.credentials.source = STATIC_TOKEN

2714 bearer.auth.custom.provider.class = null

2715 bearer.auth.identity.pool.id = null

2716 bearer.auth.issuer.endpoint.url = null

2717 bearer.auth.logical.cluster = null

2718 bearer.auth.scope = null

2719 bearer.auth.scope.claim.name = scope

2720 bearer.auth.sub.claim.name = sub

2721 bearer.auth.token = [hidden]

2722 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2723 http.connect.timeout.ms = 60000

2724 http.read.timeout.ms = 60000

2725 id.compatibility.strict = true

2726 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2727 latest.cache.size = 1000

2728 latest.cache.ttl.sec = -1

2729 latest.compatibility.strict = true

2730 max.retries = 3

2731 max.schemas.per.subject = 1000

2732 normalize.schemas = false

2733 propagate.schema.tags = false

2734 proxy.host =

2735 proxy.port = -1

2736 retries.max.wait.ms = 20000

2737 retries.wait.ms = 1000

2738 rule.actions = []

2739 rule.executors = []

2740 rule.service.loader.enable = true

2741 schema.format = null

2742 schema.reflection = false

2743 schema.registry.basic.auth.user.info = [hidden]

2744 schema.registry.ssl.cipher.suites = null

2745 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2746 schema.registry.ssl.endpoint.identification.algorithm = https

2747 schema.registry.ssl.engine.factory.class = null

2748 schema.registry.ssl.key.password = null

2749 schema.registry.ssl.keymanager.algorithm = SunX509

2750 schema.registry.ssl.keystore.certificate.chain = null

2751 schema.registry.ssl.keystore.key = null

2752 schema.registry.ssl.keystore.location = null

2753 schema.registry.ssl.keystore.password = null

2754 schema.registry.ssl.keystore.type = JKS

2755 schema.registry.ssl.protocol = TLSv1.3

2756 schema.registry.ssl.provider = null

2757 schema.registry.ssl.secure.random.implementation = null

2758 schema.registry.ssl.trustmanager.algorithm = PKIX

2759 schema.registry.ssl.truststore.certificates = null

2760 schema.registry.ssl.truststore.location = null

2761 schema.registry.ssl.truststore.password = null

2762 schema.registry.ssl.truststore.type = JKS

2763 schema.registry.url = []

2764 schema.registry.url.randomize = false

2765 specific.avro.key.type = null

2766 specific.avro.reader = false

2767 specific.avro.value.type = null

2768 use.latest.version = false

2769 use.latest.with.metadata = null

2770 use.schema.id = -1

2771 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2772

2773[info] - can create a deserializer (11 milliseconds)

2774[info] - raises schema errors (5 milliseconds)

277500:07:20.833 [io-compute-0] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig -- KafkaAvroDeserializerConfig values:

2776 auto.register.schemas = true

2777 avro.reflection.allow.null = false

2778 avro.use.logical.type.converters = false

2779 basic.auth.credentials.source = URL

2780 basic.auth.user.info = [hidden]

2781 bearer.auth.cache.expiry.buffer.seconds = 300

2782 bearer.auth.client.id = null

2783 bearer.auth.client.secret = null

2784 bearer.auth.credentials.source = STATIC_TOKEN

2785 bearer.auth.custom.provider.class = null

2786 bearer.auth.identity.pool.id = null

2787 bearer.auth.issuer.endpoint.url = null

2788 bearer.auth.logical.cluster = null

2789 bearer.auth.scope = null

2790 bearer.auth.scope.claim.name = scope

2791 bearer.auth.sub.claim.name = sub

2792 bearer.auth.token = [hidden]

2793 context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy

2794 http.connect.timeout.ms = 60000

2795 http.read.timeout.ms = 60000

2796 id.compatibility.strict = true

2797 key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2798 latest.cache.size = 1000

2799 latest.cache.ttl.sec = -1

2800 latest.compatibility.strict = true

2801 max.retries = 3

2802 max.schemas.per.subject = 1000

2803 normalize.schemas = false

2804 propagate.schema.tags = false

2805 proxy.host =

2806 proxy.port = -1

2807 retries.max.wait.ms = 20000

2808 retries.wait.ms = 1000

2809 rule.actions = []

2810 rule.executors = []

2811 rule.service.loader.enable = true

2812 schema.format = null

2813 schema.reflection = false

2814 schema.registry.basic.auth.user.info = [hidden]

2815 schema.registry.ssl.cipher.suites = null

2816 schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2817 schema.registry.ssl.endpoint.identification.algorithm = https

2818 schema.registry.ssl.engine.factory.class = null

2819 schema.registry.ssl.key.password = null

2820 schema.registry.ssl.keymanager.algorithm = SunX509

2821 schema.registry.ssl.keystore.certificate.chain = null

2822 schema.registry.ssl.keystore.key = null

2823 schema.registry.ssl.keystore.location = null

2824 schema.registry.ssl.keystore.password = null

2825 schema.registry.ssl.keystore.type = JKS

2826 schema.registry.ssl.protocol = TLSv1.3

2827 schema.registry.ssl.provider = null

2828 schema.registry.ssl.secure.random.implementation = null

2829 schema.registry.ssl.trustmanager.algorithm = PKIX

2830 schema.registry.ssl.truststore.certificates = null

2831 schema.registry.ssl.truststore.location = null

2832 schema.registry.ssl.truststore.password = null

2833 schema.registry.ssl.truststore.type = JKS

2834 schema.registry.url = []

2835 schema.registry.url.randomize = false

2836 specific.avro.key.type = null

2837 specific.avro.reader = false

2838 specific.avro.value.type = null

2839 use.latest.version = false

2840 use.latest.with.metadata = null

2841 use.schema.id = -1

2842 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy

2843

2844[info] - raises IllegalArgumentException if the data is null (7 milliseconds)

2845[info] - toString (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 (63 milliseconds)

2852[info] - Timestamp.eqLaws.eq.reflexivity eq (4 milliseconds)

2853[info] - Timestamp.eqLaws.eq.symmetry eq (10 milliseconds)

2854[info] - Timestamp.eqLaws.eq.transitivity eq (8 milliseconds)

2855[info] UnexpectedTopicExceptionSpec:

2856[info] UnexpectedTopicException

2857[info] - should have expected message and toString (7 milliseconds)

2858[info] IsolationLevelSpec:

2859[info] IsolationLevel

2860[info] - should have toString matching name (1 millisecond)

2861[info] JitterSpec:

2862[info] Jitter#default

2863[info] - should always apply jitter on values (261 milliseconds)

2864[info] Jitter#none

2865[info] - should never apply jitter on values (3 milliseconds)

2866[info] SerializationExceptionSpec:

2867[info] SerializationException

2868[info] - should have expected message and toString (1 millisecond)

2869[info] ConsumerRecordLawsSpec:

2870[info] - ConsumerRecord.eqLaws.eq.antisymmetry eq (74 milliseconds)

2871[info] - ConsumerRecord.eqLaws.eq.reflexivity eq (18 milliseconds)

2872[info] - ConsumerRecord.eqLaws.eq.symmetry eq (25 milliseconds)

2873[info] - ConsumerRecord.eqLaws.eq.transitivity eq (21 milliseconds)

2874[info] - ConsumerRecord.traverseLaws.traverse.collectFirst reference (28 milliseconds)

2875[info] - ConsumerRecord.traverseLaws.traverse.collectFirstSome reference (16 milliseconds)

2876[info] - ConsumerRecord.traverseLaws.traverse.contains all elements from itself (11 milliseconds)

2877[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with exists (10 milliseconds)

2878[info] - ConsumerRecord.traverseLaws.traverse.contains consistent with forall (14 milliseconds)

2879[info] - ConsumerRecord.traverseLaws.traverse.covariant composition (20 milliseconds)

2880[info] - ConsumerRecord.traverseLaws.traverse.covariant identity (10 milliseconds)

2881[info] - ConsumerRecord.traverseLaws.traverse.dropWhile_ reference (10 milliseconds)

2882[info] - ConsumerRecord.traverseLaws.traverse.exists consistent with find (5 milliseconds)

2883[info] - ConsumerRecord.traverseLaws.traverse.exists is lazy (8 milliseconds)

2884[info] - ConsumerRecord.traverseLaws.traverse.filter_ reference (7 milliseconds)

2885[info] - ConsumerRecord.traverseLaws.traverse.fold reference (5 milliseconds)

2886[info] - ConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (10 milliseconds)

2887[info] - ConsumerRecord.traverseLaws.traverse.foldM identity (17 milliseconds)

2888[info] - ConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (8 milliseconds)

2889[info] - ConsumerRecord.traverseLaws.traverse.foldRight is lazy (6 milliseconds)

2890[info] - ConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (10 milliseconds)

2891[info] - ConsumerRecord.traverseLaws.traverse.forall consistent with exists (7 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 (11 milliseconds)

2895[info] - ConsumerRecord.traverseLaws.traverse.invariant composition (11 milliseconds)

2896[info] - ConsumerRecord.traverseLaws.traverse.invariant identity (5 milliseconds)

2897[info] - ConsumerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (8 milliseconds)

2898[info] - ConsumerRecord.traverseLaws.traverse.nonEmpty reference (5 milliseconds)

2899[info] - ConsumerRecord.traverseLaws.traverse.ordered consistency (6 milliseconds)

2900[info] - ConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (4 milliseconds)

2901[info] - ConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (6 milliseconds)

2902[info] - ConsumerRecord.traverseLaws.traverse.takeWhile_ reference (6 milliseconds)

2903[info] - ConsumerRecord.traverseLaws.traverse.toList reference (5 milliseconds)

2904[info] - ConsumerRecord.traverseLaws.traverse.traverse derive foldMap (18 milliseconds)

2905[info] - ConsumerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

2906[info] - ConsumerRecord.traverseLaws.traverse.traverse order consistency (4 milliseconds)

2907[info] - ConsumerRecord.traverseLaws.traverse.traverse parallel composition (6 milliseconds)

2908[info] - ConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (25 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 (5 milliseconds)

2914[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithIndex (4 milliseconds)

2915[info] - ConsumerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (6 milliseconds)

2916[info] - ConsumerRecord.traverseLaws.traverse.traverse sequential composition (13 milliseconds)

2917[info] - ConsumerRecord.traverseLaws.traverse.traverse traverseTap (5 milliseconds)

2918[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (6 milliseconds)

2919[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (7 milliseconds)

2920[info] - ConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (6 milliseconds)

2921[info] - ConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (5 milliseconds)

2922[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (5 milliseconds)

2923[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (7 milliseconds)

2924[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (4 milliseconds)

2925[info] - ConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (10 milliseconds)

2926[info] - ConsumerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (5 milliseconds)

2927[info] - ConsumerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (5 milliseconds)

2928[info] - ConsumerRecord.bitraverseLaws.bitraverse.bitraverse composition (7 milliseconds)

2929[info] - ConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 milliseconds)

2930[info] CommitTimeoutExceptionSpec:

2931[info] CommitTimeoutException

2932[info] - should have expected message and toString (17 milliseconds)

2933[info] TimestampSpec:

2934[info] Timeout#createTime

2935[info] - should have a createTime (8 milliseconds)

2936[info] - should not have a logAppendTime (1 millisecond)

2937[info] - should not have an unknownTime (0 milliseconds)

2938[info] - should include the createTime in toString (6 milliseconds)

2939[info] Timeout#logAppendTime

2940[info] - should have a logAppendTime (1 millisecond)

2941[info] - should not have a createTime (2 milliseconds)

2942[info] - should not have an unknownTime (1 millisecond)

2943[info] - should include the logAppendTime in toString (1 millisecond)

2944[info] Timeout#unknownTime

2945[info] - should not have a logAppendTime (2 milliseconds)

2946[info] - should not have a createTime (1 millisecond)

2947[info] - should have an unknownTime (1 millisecond)

2948[info] - should include the unknownTime in toString (1 millisecond)

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 (1 millisecond)

2953[info] - should be empty (0 milliseconds)

2954[info] - should not include any time in toString (0 milliseconds)

2955[info] CommittableConsumerRecordSpec:

2956[info] CommittableConsumerRecord

2957[info] - should have a Show instance and matching toString (4 milliseconds)

2958[info] KafkaSpec:

2959[info] commitBatchWithin

2960[info] - should batch commit according specified arguments (149 milliseconds)

2961[info] ProducerRecordLawsSpec:

2962[info] - ProducerRecord.eqLaws.eq.antisymmetry eq (6 milliseconds)

2963[info] - ProducerRecord.eqLaws.eq.reflexivity eq (4 milliseconds)

2964[info] - ProducerRecord.eqLaws.eq.symmetry eq (5 milliseconds)

2965[info] - ProducerRecord.eqLaws.eq.transitivity eq (11 milliseconds)

2966[info] - ProducerRecord.traverseLaws.traverse.collectFirst reference (4 milliseconds)

2967[info] - ProducerRecord.traverseLaws.traverse.collectFirstSome reference (5 milliseconds)

2968[info] - ProducerRecord.traverseLaws.traverse.contains all elements from itself (4 milliseconds)

2969[info] - ProducerRecord.traverseLaws.traverse.contains consistent with exists (4 milliseconds)

2970[info] - ProducerRecord.traverseLaws.traverse.contains consistent with forall (5 milliseconds)

2971[info] - ProducerRecord.traverseLaws.traverse.covariant composition (4 milliseconds)

2972[info] - ProducerRecord.traverseLaws.traverse.covariant identity (3 milliseconds)

2973[info] - ProducerRecord.traverseLaws.traverse.dropWhile_ reference (5 milliseconds)

2974[info] - ProducerRecord.traverseLaws.traverse.exists consistent with find (4 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 (3 milliseconds)

2978[info] - ProducerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (5 milliseconds)

2979[info] - ProducerRecord.traverseLaws.traverse.foldM identity (4 milliseconds)

2980[info] - ProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (5 milliseconds)

2981[info] - ProducerRecord.traverseLaws.traverse.foldRight is lazy (4 milliseconds)

2982[info] - ProducerRecord.traverseLaws.traverse.foldRightDefer consistency (6 milliseconds)

2983[info] - ProducerRecord.traverseLaws.traverse.forall consistent with exists (4 milliseconds)

2984[info] - ProducerRecord.traverseLaws.traverse.forall is lazy (3 milliseconds)

2985[info] - ProducerRecord.traverseLaws.traverse.forall true if empty (4 milliseconds)

2986[info] - ProducerRecord.traverseLaws.traverse.get reference (4 milliseconds)

2987[info] - ProducerRecord.traverseLaws.traverse.invariant composition (4 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 (5 milliseconds)

2992[info] - ProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (4 milliseconds)

2993[info] - ProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (4 milliseconds)

2994[info] - ProducerRecord.traverseLaws.traverse.takeWhile_ reference (5 milliseconds)

2995[info] - ProducerRecord.traverseLaws.traverse.toList reference (2 milliseconds)

2996[info] - ProducerRecord.traverseLaws.traverse.traverse derive foldMap (5 milliseconds)

2997[info] - ProducerRecord.traverseLaws.traverse.traverse identity (3 milliseconds)

2998[info] - ProducerRecord.traverseLaws.traverse.traverse order consistency (4 milliseconds)

2999[info] - ProducerRecord.traverseLaws.traverse.traverse parallel composition (4 milliseconds)

3000[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (9 milliseconds)

3001[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (5 milliseconds)

3002[info] - ProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (3 milliseconds)

3003[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (2 milliseconds)

3004[info] - ProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (4 milliseconds)

3005[info] - ProducerRecord.traverseLaws.traverse.traverse ref updated (2 milliseconds)

3006[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (3 milliseconds)

3007[info] - ProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (3 milliseconds)

3008[info] - ProducerRecord.traverseLaws.traverse.traverse sequential composition (2 milliseconds)

3009[info] - ProducerRecord.traverseLaws.traverse.traverse traverseTap (2 milliseconds)

3010[info] - ProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (2 milliseconds)

3011[info] - ProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (3 milliseconds)

3012[info] - ProducerRecord.traverseLaws.traverse.unordered traverse sequential composition (4 milliseconds)

3013[info] - ProducerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (2 milliseconds)

3014[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (3 milliseconds)

3015[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (5 milliseconds)

3016[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (2 milliseconds)

3017[info] - ProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (3 milliseconds)

3018[info] - ProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (3 milliseconds)

3019[info] - ProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (4 milliseconds)

3020[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (3 milliseconds)

3021[info] - ProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 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 (5 milliseconds)

3028[info] - should provide withBootstrapServers (0 milliseconds)

3029[info] - should provide withAutoOffsetReset (0 milliseconds)

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 (1 millisecond)

3034[info] - should provide withGroupInstanceId (0 milliseconds)

3035[info] - should provide withMaxPollRecords (0 milliseconds)

3036[info] - should provide withMaxPollInterval (1 millisecond)

3037[info] - should provide withSessionTimeout (0 milliseconds)

3038[info] - should provide withHeartbeatInterval (1 millisecond)

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 (0 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 (0 milliseconds)

3050[info] - should provide withCommitRecovery (0 milliseconds)

3051[info] - should provide withRecordMetadata (7 milliseconds)

3052[info] - should provide withMaxPrefetchBatches (0 milliseconds)

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 (5 milliseconds)

3055[info] - should have a Show instance and matching toString (5 milliseconds)

3056[info] ConsumerShutdownExceptionSpec:

3057[info] ConsumerShutdownException

3058[info] - should have expected message and toString (1 millisecond)

3059[info] HeaderSerializerSpec:

3060[info] - HeaderSerializer.contravariant.contravariant composition (97 milliseconds)

3061[info] - HeaderSerializer.contravariant.contravariant identity (47 milliseconds)

3062[info] - HeaderSerializer.contravariant.invariant composition (51 milliseconds)

3063[info] - HeaderSerializer.contravariant.invariant identity (44 milliseconds)

3064[info] - HeaderSerializer#mapBytes (5 milliseconds)

3065[info] - HeaderSerializer#const (1 millisecond)

3066[info] - HeaderSerializer#asNull (1 millisecond)

3067[info] - HeaderSerializer#empty (2 milliseconds)

3068[info] - HeaderSerializer#option (3 milliseconds)

3069[info] - HeaderSerializer#unit (0 milliseconds)

3070[info] - HeaderSerializer#toString (1 millisecond)

3071[info] - HeaderSerializer#string (5 milliseconds)

3072[info] - HeaderSerializer#uuid (5 milliseconds)

3073[info] - HeaderSerializer#double (1 millisecond)

3074[info] - HeaderSerializer#float (2 milliseconds)

3075[info] - HeaderSerializer#int (1 millisecond)

3076[info] - HeaderSerializer#long (1 millisecond)

3077[info] - HeaderSerializer#short (3 milliseconds)

3078[info] HeadersLawsSpec:

3079[info] - Headers.eqLaws.eq.antisymmetry eq (5 milliseconds)

3080[info] - Headers.eqLaws.eq.reflexivity eq (2 milliseconds)

3081[info] - Headers.eqLaws.eq.symmetry eq (2 milliseconds)

3082[info] - Headers.eqLaws.eq.transitivity eq (3 milliseconds)

3083[info] CommittableOffsetBatchSpec:

3084[info] CommittableOffsetBatch#empty

3085[info] - should have no offsets (0 milliseconds)

3086[info] - should return updated offset as batch (3 milliseconds)

3087[info] CommittableOffsetBatch#updated

3088[info] - should include the provided offset (15 milliseconds)

3089[info] - should override using the provided offset (16 milliseconds)

3090[info] - should be able to update with batch (11 milliseconds)

3091[info] CommittableOffsetBatch#toString

3092[info] - should provide a Show instance and matching toString (3 milliseconds)

3093[info] ProducerSettingsSpec:

3094[info] ProducerSettings

3095[info] - should provide apply (0 milliseconds)

3096[info] - should provide withBootstrapServers (0 milliseconds)

3097[info] - should provide withAcks (1 millisecond)

3098[info] - should provide withBatchSize (0 milliseconds)

3099[info] - should provide withClientId (1 millisecond)

3100[info] - should provide withRetries (0 milliseconds)

3101[info] - should provide withMaxInFlightRequestsPerConnection (0 milliseconds)

3102[info] - should provide withEnableIdempotence (0 milliseconds)

3103[info] - should provide withLinger (0 milliseconds)

3104[info] - should provide withRequestTimeout (0 milliseconds)

3105[info] - should provide withDeliveryTimeout (0 milliseconds)

3106[info] - should provide withProperty/withProperties (1 millisecond)

3107[info] - should provide withCloseTimeout (0 milliseconds)

3108[info] - should have a Show instance and matching toString (1 millisecond)

3109[info] - should be able to create with and without serializer creation effects (0 milliseconds)

3110[info] - should be able to implicitly create with and without serializer creation effects (4 milliseconds)

3111[info] - should be able to set a custom blocking context (1 millisecond)

3112[info] - should provide failFastProduce default value (0 milliseconds)

3113[info] - should be able to set failFastProduce (0 milliseconds)

3114[info] ConsumerRecordSpec:

3115[info] ConsumerRecord#fromJava

3116[info] - should convert timestamps (7 milliseconds)

3117[info] - should convert serialized key size (1 millisecond)

3118[info] - should convert serialized value size (1 millisecond)

3119[info] - should convert leader epoch (2 milliseconds)

3120[info] ConsumerRecord#toString

3121[info] - should include headers when present (1 millisecond)

3122[info] - should include timestamp if present (0 milliseconds)

3123[info] - should include serialized key size if present (0 milliseconds)

3124[info] - should include serialized value size if present (0 milliseconds)

3125[info] - should include leader epoch if present (0 milliseconds)

3126[info] AcksSpec:

3127[info] Acks

3128[info] - should have toString matching name (0 milliseconds)

3129[info] CommitRecoverySpec:

3130[info] CommitRecovery#Default

3131[info] - should retry org.apache.kafka.clients.consumer.RetriableCommitFailedException: retriable with jittered exponential backoff and fixed rate (16 milliseconds)

3132[info] - should retry org.apache.kafka.common.errors.RebalanceInProgressException with jittered exponential backoff and fixed rate (2 milliseconds)

3133[info] - should not recover non-retriable exceptions (2 milliseconds)

3134[info] - should have Default as String representation (0 milliseconds)

3135[info] CommitRecovery#None

3136[info] - should not recover any exceptions (2 milliseconds)

3137[info] - should have None as String representation (0 milliseconds)

3138[info] CommittableOffsetLawsSpec:

3139[info] - CommittableOffset.eqLaws.eq.antisymmetry eq (3 milliseconds)

3140[info] - CommittableOffset.eqLaws.eq.reflexivity eq (4 milliseconds)

3141[info] - CommittableOffset.eqLaws.eq.symmetry eq (3 milliseconds)

3142[info] - CommittableOffset.eqLaws.eq.transitivity eq (3 milliseconds)

3143[info] CommittableProducerRecordsLawsSpec:

3144[info] - CommittableProducerRecord.eqLaws.eq.antisymmetry eq (6 milliseconds)

3145[info] - CommittableProducerRecord.eqLaws.eq.reflexivity eq (3 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 (4 milliseconds)

3150[info] - CommittableProducerRecord.traverseLaws.traverse.contains all elements from itself (10 milliseconds)

3151[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with exists (3 milliseconds)

3152[info] - CommittableProducerRecord.traverseLaws.traverse.contains consistent with forall (4 milliseconds)

3153[info] - CommittableProducerRecord.traverseLaws.traverse.covariant composition (8 milliseconds)

3154[info] - CommittableProducerRecord.traverseLaws.traverse.covariant identity (4 milliseconds)

3155[info] - CommittableProducerRecord.traverseLaws.traverse.dropWhile_ reference (3 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 (8 milliseconds)

3161[info] - CommittableProducerRecord.traverseLaws.traverse.foldM identity (7 milliseconds)

3162[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight consistent with foldMap (8 milliseconds)

3163[info] - CommittableProducerRecord.traverseLaws.traverse.foldRight is lazy (4 milliseconds)

3164[info] - CommittableProducerRecord.traverseLaws.traverse.foldRightDefer consistency (7 milliseconds)

3165[info] - CommittableProducerRecord.traverseLaws.traverse.forall consistent with exists (3 milliseconds)

3166[info] - CommittableProducerRecord.traverseLaws.traverse.forall is lazy (5 milliseconds)

3167[info] - CommittableProducerRecord.traverseLaws.traverse.forall true if empty (4 milliseconds)

3168[info] - CommittableProducerRecord.traverseLaws.traverse.get reference (6 milliseconds)

3169[info] - CommittableProducerRecord.traverseLaws.traverse.invariant composition (11 milliseconds)

3170[info] - CommittableProducerRecord.traverseLaws.traverse.invariant identity (8 milliseconds)

3171[info] - CommittableProducerRecord.traverseLaws.traverse.mapOrKeepToMapEquivalence (5 milliseconds)

3172[info] - CommittableProducerRecord.traverseLaws.traverse.nonEmpty reference (4 milliseconds)

3173[info] - CommittableProducerRecord.traverseLaws.traverse.ordered consistency (5 milliseconds)

3174[info] - CommittableProducerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (4 milliseconds)

3175[info] - CommittableProducerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (5 milliseconds)

3176[info] - CommittableProducerRecord.traverseLaws.traverse.takeWhile_ reference (4 milliseconds)

3177[info] - CommittableProducerRecord.traverseLaws.traverse.toList reference (4 milliseconds)

3178[info] - CommittableProducerRecord.traverseLaws.traverse.traverse derive foldMap (7 milliseconds)

3179[info] - CommittableProducerRecord.traverseLaws.traverse.traverse identity (8 milliseconds)

3180[info] - CommittableProducerRecord.traverseLaws.traverse.traverse order consistency (5 milliseconds)

3181[info] - CommittableProducerRecord.traverseLaws.traverse.traverse parallel composition (6 milliseconds)

3182[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapAccumulate (9 milliseconds)

3183[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithIndex (5 milliseconds)

3184[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (4 milliseconds)

3185[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (5 milliseconds)

3186[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (5 milliseconds)

3187[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref updated (4 milliseconds)

3188[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithIndex (5 milliseconds)

3189[info] - CommittableProducerRecord.traverseLaws.traverse.traverse ref zipWithLongIndex (7 milliseconds)

3190[info] - CommittableProducerRecord.traverseLaws.traverse.traverse sequential composition (5 milliseconds)

3191[info] - CommittableProducerRecord.traverseLaws.traverse.traverse traverseTap (5 milliseconds)

3192[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (4 milliseconds)

3193[info] - CommittableProducerRecord.traverseLaws.traverse.unordered traverse parallel composition (7 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 (3 milliseconds)

3197[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (4 milliseconds)

3198[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (3 milliseconds)

3199[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (3 milliseconds)

3200[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldLeft consistent with bifoldMap (6 milliseconds)

3201[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bifoldRight consistent with bifoldMap (6 milliseconds)

3202[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse composition (5 milliseconds)

3203[info] - CommittableProducerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 milliseconds)

3204[info] HeaderDeserializerSpec:

3205[info] - HeaderDeserializer.monad.ap consistent with product + map (57 milliseconds)

3206[info] - HeaderDeserializer.monad.applicative homomorphism (36 milliseconds)

3207[info] - HeaderDeserializer.monad.applicative identity (29 milliseconds)

3208[info] - HeaderDeserializer.monad.applicative interchange (34 milliseconds)

3209[info] - HeaderDeserializer.monad.applicative map (32 milliseconds)

3210[info] - HeaderDeserializer.monad.applicative unit (22 milliseconds)

3211[info] - HeaderDeserializer.monad.apply composition (42 milliseconds)

3212[info] - HeaderDeserializer.monad.covariant composition (29 milliseconds)

3213[info] - HeaderDeserializer.monad.covariant identity (31 milliseconds)

3214[info] - HeaderDeserializer.monad.flatMap associativity (31 milliseconds)

3215[info] - HeaderDeserializer.monad.flatMap consistent apply (25 milliseconds)

3216[info] - HeaderDeserializer.monad.flatMap from tailRecM consistency (33 milliseconds)

3217[info] - HeaderDeserializer.monad.invariant composition (29 milliseconds)

3218[info] - HeaderDeserializer.monad.invariant identity (23 milliseconds)

3219[info] - HeaderDeserializer.monad.map flatMap coherence (29 milliseconds)

3220[info] - HeaderDeserializer.monad.map2/map2Eval consistency (32 milliseconds)

3221[info] - HeaderDeserializer.monad.map2/product-map consistency (29 milliseconds)

3222[info] - HeaderDeserializer.monad.mapOrKeepToMapEquivalence (32 milliseconds)

3223[info] - HeaderDeserializer.monad.monad left identity (22 milliseconds)

3224[info] - HeaderDeserializer.monad.monad right identity (20 milliseconds)

3225[info] - HeaderDeserializer.monad.monoidal left identity (22 milliseconds)

3226[info] - HeaderDeserializer.monad.monoidal right identity (22 milliseconds)

3227[info] - HeaderDeserializer.monad.mproduct consistent flatMap (32 milliseconds)

3228[info] - HeaderDeserializer.monad.productL consistent map2 (17 milliseconds)

3229[info] - HeaderDeserializer.monad.productR consistent map2 (23 milliseconds)

3230[info] - HeaderDeserializer.monad.replicateA_ consistent with replicateA.void (36 milliseconds)

3231[info] - HeaderDeserializer.monad.semigroupal associativity (35 milliseconds)

3232[info] - HeaderDeserializer.monad.tailRecM consistent flatMap (27 milliseconds)

3233[info] - HeaderDeserializer.monad.tailRecM stack safety (65 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 (4 milliseconds)

3240[info] - CommittableConsumerRecord.eqLaws.eq.reflexivity eq (2 milliseconds)

3241[info] - CommittableConsumerRecord.eqLaws.eq.symmetry eq (3 milliseconds)

3242[info] - CommittableConsumerRecord.eqLaws.eq.transitivity eq (4 milliseconds)

3243[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirst reference (2 milliseconds)

3244[info] - CommittableConsumerRecord.traverseLaws.traverse.collectFirstSome reference (3 milliseconds)

3245[info] - CommittableConsumerRecord.traverseLaws.traverse.contains all elements from itself (2 milliseconds)

3246[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with exists (3 milliseconds)

3247[info] - CommittableConsumerRecord.traverseLaws.traverse.contains consistent with forall (3 milliseconds)

3248[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant composition (3 milliseconds)

3249[info] - CommittableConsumerRecord.traverseLaws.traverse.covariant identity (4 milliseconds)

3250[info] - CommittableConsumerRecord.traverseLaws.traverse.dropWhile_ reference (3 milliseconds)

3251[info] - CommittableConsumerRecord.traverseLaws.traverse.exists consistent with find (4 milliseconds)

3252[info] - CommittableConsumerRecord.traverseLaws.traverse.exists is lazy (2 milliseconds)

3253[info] - CommittableConsumerRecord.traverseLaws.traverse.filter_ reference (2 milliseconds)

3254[info] - CommittableConsumerRecord.traverseLaws.traverse.fold reference (4 milliseconds)

3255[info] - CommittableConsumerRecord.traverseLaws.traverse.foldLeft consistent with foldMap (3 milliseconds)

3256[info] - CommittableConsumerRecord.traverseLaws.traverse.foldM identity (4 milliseconds)

3257[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight consistent with foldMap (4 milliseconds)

3258[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRight is lazy (3 milliseconds)

3259[info] - CommittableConsumerRecord.traverseLaws.traverse.foldRightDefer consistency (4 milliseconds)

3260[info] - CommittableConsumerRecord.traverseLaws.traverse.forall consistent with exists (3 milliseconds)

3261[info] - CommittableConsumerRecord.traverseLaws.traverse.forall is lazy (2 milliseconds)

3262[info] - CommittableConsumerRecord.traverseLaws.traverse.forall true if empty (3 milliseconds)

3263[info] - CommittableConsumerRecord.traverseLaws.traverse.get reference (3 milliseconds)

3264[info] - CommittableConsumerRecord.traverseLaws.traverse.invariant composition (4 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 (2 milliseconds)

3268[info] - CommittableConsumerRecord.traverseLaws.traverse.ordered consistency (3 milliseconds)

3269[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceLeftOption consistent with reduceLeftToOption (3 milliseconds)

3270[info] - CommittableConsumerRecord.traverseLaws.traverse.reduceRightOption consistent with reduceRightToOption (3 milliseconds)

3271[info] - CommittableConsumerRecord.traverseLaws.traverse.takeWhile_ reference (3 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 (1 millisecond)

3277[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapAccumulate (3 milliseconds)

3278[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithIndex (3 milliseconds)

3279[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref mapWithLongIndex (4 milliseconds)

3280[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithIndexM (3 milliseconds)

3281[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref traverseWithLongIndexM (2 milliseconds)

3282[info] - CommittableConsumerRecord.traverseLaws.traverse.traverse ref updated (4 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 (3 milliseconds)

3287[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse consistent with sequence (2 milliseconds)

3288[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse parallel composition (3 milliseconds)

3289[info] - CommittableConsumerRecord.traverseLaws.traverse.unordered traverse sequential composition (3 milliseconds)

3290[info] - CommittableConsumerRecord.traverseLaws.traverse.unorderedFold consistent with unorderedFoldMap (3 milliseconds)

3291[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor Identity (3 milliseconds)

3292[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor associativity (4 milliseconds)

3293[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap Identity (2 milliseconds)

3294[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.Bifunctor leftMap associativity (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 (4 milliseconds)

3298[info] - CommittableConsumerRecord.bitraverseLaws.bitraverse.bitraverse identity (3 milliseconds)

3299[info] DeserializationExceptionSpec:

3300[info] DeserializationException

3301[info] - should have expected message and toString (1 millisecond)

3302[info] HeaderSpec:

3303[info] Header

3304[info] - toString should be Header(key -> value) (1 millisecond)

3305[info] - should have consistent toString and Show (0 milliseconds)

3306[info] - should return the key with key (0 milliseconds)

3307[info] - should return the value with value (1 millisecond)

3308[info] - should deserialize with as (0 milliseconds)

3309[info] - should deserialize with attemptAs (1 millisecond)

3310[info] HeaderLawsSpec:

3311[info] - Header.eqLaws.eq.antisymmetry eq (3 milliseconds)

3312[info] - Header.eqLaws.eq.reflexivity eq (2 milliseconds)

3313[info] - Header.eqLaws.eq.symmetry eq (3 milliseconds)

3314[info] - Header.eqLaws.eq.transitivity eq (2 milliseconds)

3315[info] SerializerSpec:

3316[info] - Serializer[IO, *].contravariant.contravariant composition (340 milliseconds)

3317[info] - Serializer[IO, *].contravariant.contravariant identity (257 milliseconds)

3318[info] - Serializer[IO, *].contravariant.invariant composition (188 milliseconds)

3319[info] - Serializer[IO, *].contravariant.invariant identity (86 milliseconds)

3320[info] - Serializer#mapBytes (4 milliseconds)

3321[info] - Serializer#apply (4 milliseconds)

3322[info] - Serializer#identity (8 milliseconds)

3323[info] - Serializer#const (2 milliseconds)

3324[info] - Serializer#defer (12 milliseconds)

3325[info] - Serializer#fail (9 milliseconds)

3326[info] - Serializer#failWith (8 milliseconds)

3327[info] - Serializer#suspend (11 milliseconds)

3328[info] - Serializer#headers (20 milliseconds)

3329[info] - Serializer#topic (16 milliseconds)

3330[info] - Serializer#topic.unknown (11 milliseconds)

3331[info] - Serializer#asNull (5 milliseconds)

3332[info] - Serializer#empty (2 milliseconds)

3333[info] - Serializer#option (4 milliseconds)

3334[info] - Serializer#unit (0 milliseconds)

3335[info] - Serializer#toString (0 milliseconds)

3336[info] - Serializer#string (6 milliseconds)

3337[info] - Serializer#uuid (10 milliseconds)

3338[info] - Serializer#uuid.default (6 milliseconds)

3339[info] - Serializer#double (7 milliseconds)

3340[info] - Serializer#float (7 milliseconds)

3341[info] - Serializer#int (5 milliseconds)

3342[info] - Serializer#long (7 milliseconds)

3343[info] - Serializer#short (3 milliseconds)

3344[info] DeserializerSpec:

3345[info] - Deserializer[IO, *].monadError.ap consistent with product + map (162 milliseconds)

3346[info] - Deserializer[IO, *].monadError.applicative homomorphism (116 milliseconds)

3347[info] - Deserializer[IO, *].monadError.applicative identity (94 milliseconds)

3348[info] - Deserializer[IO, *].monadError.applicative interchange (86 milliseconds)

3349[info] - Deserializer[IO, *].monadError.applicative map (83 milliseconds)

3350[info] - Deserializer[IO, *].monadError.applicative unit (79 milliseconds)

3351[info] - Deserializer[IO, *].monadError.applicativeError adaptError pure (80 milliseconds)

3352[info] - Deserializer[IO, *].monadError.applicativeError adaptError raise (121 milliseconds)

3353[info] - Deserializer[IO, *].monadError.applicativeError attempt consistent with attemptT (85 milliseconds)

3354[info] - Deserializer[IO, *].monadError.applicativeError attempt fromEither consistent with pure (82 milliseconds)

3355[info] - Deserializer[IO, *].monadError.applicativeError handle (95 milliseconds)

3356[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError left-distributes over ap (97 milliseconds)

3357[info] - Deserializer[IO, *].monadError.applicativeError handleError . raiseError right-distributes over ap (85 milliseconds)

3358[info] - Deserializer[IO, *].monadError.applicativeError handleError consistent with recover (87 milliseconds)

3359[info] - Deserializer[IO, *].monadError.applicativeError handleError pure (61 milliseconds)

3360[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith consistent with recoverWith (66 milliseconds)

3361[info] - Deserializer[IO, *].monadError.applicativeError handleErrorWith pure (66 milliseconds)

3362[info] - Deserializer[IO, *].monadError.applicativeError handleWith (81 milliseconds)

3363[info] - Deserializer[IO, *].monadError.applicativeError onError pure (62 milliseconds)

3364[info] - Deserializer[IO, *].monadError.applicativeError onError raise (74 milliseconds)

3365[info] - Deserializer[IO, *].monadError.applicativeError pure attempt (80 milliseconds)

3366[info] - Deserializer[IO, *].monadError.applicativeError raiseError attempt (87 milliseconds)

3367[info] - Deserializer[IO, *].monadError.applicativeError recover consistent with recoverWith (67 milliseconds)

3368[info] - Deserializer[IO, *].monadError.applicativeError redeem is derived from attempt and map (66 milliseconds)

3369[info] - Deserializer[IO, *].monadError.applicativeError voidError consistent with void+handleError (62 milliseconds)

3370[info] - Deserializer[IO, *].monadError.apply composition (72 milliseconds)

3371[info] - Deserializer[IO, *].monadError.covariant composition (73 milliseconds)

3372[info] - Deserializer[IO, *].monadError.covariant identity (80 milliseconds)

3373[info] - Deserializer[IO, *].monadError.flatMap associativity (73 milliseconds)

3374[info] - Deserializer[IO, *].monadError.flatMap consistent apply (68 milliseconds)

3375[info] - Deserializer[IO, *].monadError.flatMap from tailRecM consistency (84 milliseconds)

3376[info] - Deserializer[IO, *].monadError.invariant composition (61 milliseconds)

3377[info] - Deserializer[IO, *].monadError.invariant identity (60 milliseconds)

3378[info] - Deserializer[IO, *].monadError.map flatMap coherence (63 milliseconds)

3379[info] - Deserializer[IO, *].monadError.map2/map2Eval consistency (71 milliseconds)

3380[info] - Deserializer[IO, *].monadError.map2/product-map consistency (74 milliseconds)

3381[info] - Deserializer[IO, *].monadError.mapOrKeepToMapEquivalence (62 milliseconds)

3382[info] - Deserializer[IO, *].monadError.monad left identity (90 milliseconds)

3383[info] - Deserializer[IO, *].monadError.monad right identity (64 milliseconds)

3384[info] - Deserializer[IO, *].monadError.monadError ensure consistency (64 milliseconds)

3385[info] - Deserializer[IO, *].monadError.monadError ensureOr consistency (64 milliseconds)

3386[info] - Deserializer[IO, *].monadError.monadError left zero (63 milliseconds)

3387[info] - Deserializer[IO, *].monadError.monadError redeemWith is derived from attempt and flatMap (76 milliseconds)

3388[info] - Deserializer[IO, *].monadError.monadError rethrow attempt (71 milliseconds)

3389[info] - Deserializer[IO, *].monadError.monoidal left identity (66 milliseconds)

3390[info] - Deserializer[IO, *].monadError.monoidal right identity (62 milliseconds)

3391[info] - Deserializer[IO, *].monadError.mproduct consistent flatMap (153 milliseconds)

3392[info] - Deserializer[IO, *].monadError.productL consistent map2 (60 milliseconds)

3393[info] - Deserializer[IO, *].monadError.productR consistent map2 (71 milliseconds)

3394[info] - Deserializer[IO, *].monadError.replicateA_ consistent with replicateA.void (71 milliseconds)

3395[info] - Deserializer[IO, *].monadError.semigroupal associativity (70 milliseconds)

3396[info] - Deserializer[IO, *].monadError.tailRecM consistent flatMap (91 milliseconds)

3397[info] - Deserializer[IO, *].monadError.tailRecM stack safety (229 milliseconds)

3398[info] - Deserializer#attempt (7 milliseconds)

3399[info] - Deserializer#fail (7 milliseconds)

3400[info] - Deserializer#failWith (5 milliseconds)

3401[info] - Deserializer#headers (17 milliseconds)

3402[info] - Deserializer#apply (3 milliseconds)

3403[info] - Deserializer#identity (2 milliseconds)

3404[info] - Deserializer#suspend (2 milliseconds)

3405[info] - Deserializer#topic (6 milliseconds)

3406[info] - Deserializer#topic.unknown (4 milliseconds)

3407[info] - Deserializer#attempt (implicit) (4 milliseconds)

3408[info] - Deserializer#option (4 milliseconds)

3409[info] - Deserializer#unit (2 milliseconds)

3410[info] - Deserializer#toString (0 milliseconds)

3411[info] KafkaCredentialStoreSpec:

3412[info] KafkaCredentialStore

3413[info] fromPemStrings

3414[info] - should create a KafkaCredentialStore with the expected properties (1 millisecond)

3415[info] HeadersSpec:

3416[info] Headers#empty

3417[info] - should have toString as Headers() (0 milliseconds)

3418[info] - should return true for isEmpty (0 milliseconds)

3419[info] - should return false for nonEmpty (0 milliseconds)

3420[info] - should return false for exists (0 milliseconds)

3421[info] - should not find any key (1 millisecond)

3422[info] - should concat empty (0 milliseconds)

3423[info] - should concat non-empty (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

3428[info] - add(header) throws IllegalStateException (1 millisecond)

3429[info] - add(key, value) throws IllegalStateException (1 millisecond)

3430[info] - remove throws IllegalStateException (0 milliseconds)

3431[info] - lastHeader returns null (1 millisecond)

3432[info] - headers returns empty iterable (0 milliseconds)

3433[info] - toArray returns empty array (0 milliseconds)

3434[info] - iterator.next throws NoSuchElementException (1 millisecond)

3435[info] - iterator.hasNext returns false (0 milliseconds)

3436[info] Headers#nonEmpty.asJava

3437[info] - add(header) throws IllegalStateException (1 millisecond)

3438[info] - add(key, value) throws IllegalStateException (1 millisecond)

3439[info] - remove throws IllegalStateException (1 millisecond)

3440[info] - lastHeader returns last header (1 millisecond)

3441[info] - lastHeaders returns existing header (0 milliseconds)

3442[info] - lastHeader returns null for missing key (0 milliseconds)

3443[info] - headers returns matching headers (4 milliseconds)

3444[info] - headers returns empty if no matching headers (1 millisecond)

3445[info] - toArray returns elements (0 milliseconds)

3446[info] - iterator returns elements (1 millisecond)

3447[info] Headers#nonEmpty

3448[info] - should not be empty (1 millisecond)

3449[info] - should be non empty (0 milliseconds)

3450[info] - should find an existing key (0 milliseconds)

3451[info] - should find the first key (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 (0 milliseconds)

3456[info] - should include the headers in toString (0 milliseconds)

3457[info] - should append one more header with append(Header) (1 millisecond)

3458[info] - should append one more header with append(key, value) (0 milliseconds)

3459[info] Headers#apply

3460[info] - returns empty for no headers (0 milliseconds)

3461[info] - returns non-empty for at least one header (0 milliseconds)

3462[info] Headers#fromChain

3463[info] - returns empty for empty chain (0 milliseconds)

3464[info] - returns non-empty for non-empty chain (0 milliseconds)

3465[info] Headers#fromSeq

3466[info] - returns empty for empty seq (0 milliseconds)

3467[info] - returns non-empty for non-empty seq (0 milliseconds)

3468[info] Headers#fromIterable

3469[info] - returns empty for empty iterable (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