Build Logs

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

2Clonning https://github.com/softwaremill/ox.git into /build/repo using revision v1.0.2

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

4Note: switching to '9cb2ebc1df12e84198f24d8429f0ed135892788e'.

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

21Using target Scala version for migration: 3.7.4

22Migrating project for -source:3.7 using Scala 3.7.4

23----

24Preparing build for 3.7.4

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

26Append: -rewrite,REQUIRE:-source:3.7-migration

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

28----

29Starting build for 3.7.4

30Execute tests: false

31sbt project found:

32No prepare script found for project softwaremill/ox

33##################################

34Scala version: 3.7.4

35Targets: com.softwaremill.ox%core com.softwaremill.ox%cron com.softwaremill.ox%flow-reactive-streams com.softwaremill.ox%kafka com.softwaremill.ox%mdc-logback com.softwaremill.ox%otel-context

36Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.7"],"sourcePatches":[]}

37##################################

38Using extra scalacOptions: -rewrite,REQUIRE:-source:3.7-migration

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

40[sbt_options] declare -a sbt_options=()

41[process_args] java_version = '21'

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

43# Executing command line:

44java

45-Dfile.encoding=UTF-8

46-Dcommunitybuild.scala=3.7.4

47-Dcommunitybuild.project.dependencies.add=

48-Xmx7G

49-Xms4G

50-Xss8M

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

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

53-jar

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

55"setCrossScalaVersions 3.7.4"

56"++3.7.4 -v"

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

58"set every credentials := Nil"

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

60"removeScalacOptionsStartingWith -P:wartremover"

62moduleMappings

63"runBuild 3.7.4 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.7"],"sourcePatches":[]}""" com.softwaremill.ox%core com.softwaremill.ox%cron com.softwaremill.ox%flow-reactive-streams com.softwaremill.ox%kafka com.softwaremill.ox%mdc-logback com.softwaremill.ox%otel-context"

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

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

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

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

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

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

71[info] Compilation completed in 8.46s.

72[info] done compiling

73[info] loading settings for project rootProject from build.sbt...

74[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.1)

75[info] set current project to ox (in build file:/build/repo/)

76Execute setCrossScalaVersions: 3.7.4

77OpenCB::Changing crossVersion 3.3.7 -> 3.7.4 in core/crossScalaVersions

78OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in core/crossScalaVersions

79OpenCB::Changing crossVersion 3.3.7 -> 3.7.4 in flowReactiveStreams/crossScalaVersions

80OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in flowReactiveStreams/crossScalaVersions

81OpenCB::Changing crossVersion 3.3.7 -> 3.7.4 in cron/crossScalaVersions

82OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in cron/crossScalaVersions

83OpenCB::Changing crossVersion 3.3.7 -> 3.7.4 in documentation/crossScalaVersions

84OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in documentation/crossScalaVersions

85OpenCB::Changing crossVersion 3.3.7 -> 3.7.4 in rootProject/crossScalaVersions

86OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in rootProject/crossScalaVersions

87OpenCB::Changing crossVersion 3.3.7 -> 3.7.4 in otelContext/crossScalaVersions

88OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in otelContext/crossScalaVersions

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

90OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in kafka/crossScalaVersions

91OpenCB::Changing crossVersion 3.3.7 -> 3.7.4 in mdcLogback/crossScalaVersions

92OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in mdcLogback/crossScalaVersions

93[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.1)

94[info] set current project to ox (in build file:/build/repo/)

95[info] Setting Scala version to 3.7.4 on 8 projects.

96[info] Switching Scala version on:

97[info] flowReactiveStreams (3.7.4)

98[info] documentation (3.7.4)

99[info] cron (3.7.4)

100[info] * rootProject (3.7.4)

101[info] mdcLogback (3.7.4)

102[info] kafka (3.7.4)

103[info] core (3.7.4)

104[info] otelContext (3.7.4)

105[info] Excluding projects:

106[info] Reapplying settings...

107[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.1)

108[info] set current project to ox (in build file:/build/repo/)

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

110[info] Reapplying settings...

111[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.1)

112[info] set current project to ox (in build file:/build/repo/)

113[info] Defining Global / credentials, core / credentials and 6 others.

114[info] The new values will be used by Compile / scalafmtOnly, Global / pgpSelectPassphrase and 63 others.

115[info] Run `last` for details.

116[info] Reapplying settings...

117[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.1)

118[info] set current project to ox (in build file:/build/repo/)

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

120[info] Reapplying settings...

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

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

124 Did you mean flowReactiveStreams / allExcludeDependencies ?

125 , retry without global scopes

126[info] Reapplying settings...

127[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.1)

128[info] set current project to ox (in build file:/build/repo/)

129Execute removeScalacOptionsStartingWith: -P:wartremover

130[info] Reapplying settings...

131[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.1)

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

133[success] Total time: 0 s, completed Jan 8, 2026, 1:27:38 AM

134Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.7"],"sourcePatches":[]}

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

136Starting build...

137Projects: Set(flowReactiveStreams, cron, mdcLogback, kafka, core, otelContext)

138Starting build for ProjectRef(file:/build/repo/,flowReactiveStreams) (flow-reactive-streams)... [0/6]

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

140OpenCB::Exclude Scala3 specific scalacOption `REQUIRE:-source:3.7-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, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.7-migration

144[info] compiling 57 Scala sources to /build/repo/core/target/scala-3.7.4/classes ...

215[info] [patched file /build/repo/core/src/main/scala/ox/channels/SourceOps.scala]

216[info] [patched file /build/repo/core/src/main/scala/ox/flow/FlowOps.scala]

217[info] [patched file /build/repo/core/src/main/scala/ox/oxThreadFactory.scala]

218[info] [patched file /build/repo/core/src/main/scala/ox/local.scala]

219[info] [patched file /build/repo/core/src/main/scala/ox/flow/FlowReactiveOps.scala]

221[info] done compiling

222[info] compiling 1 Scala source to /build/repo/flow-reactive-streams/target/scala-3.7.4/classes ...

223[info] done compiling

224[info] compiling 5 Scala sources to /build/repo/core/target/scala-3.7.4/classes ...

240[info] done compiling

241[info] compiling 1 Scala source to /build/repo/core/target/scala-3.7.4/classes ...

243[info] done compiling

244[info] compiling 25 Scala sources to /build/repo/core/target/scala-3.7.4/classes ...

270[info] done compiling

271Starting build for ProjectRef(file:/build/repo/,mdcLogback) (mdc-logback)... [1/6]

272Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.7-migration

273[info] compiling 1 Scala source to /build/repo/mdc-logback/target/scala-3.7.4/classes ...

274[info] done compiling

275[info] compiling 1 Scala source to /build/repo/mdc-logback/target/scala-3.7.4/test-classes ...

276[info] done compiling

277Starting build for ProjectRef(file:/build/repo/,core) (core)... [2/6]

278Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.7-migration

279[info] compiling 112 Scala sources to /build/repo/core/target/scala-3.7.4/test-classes ...

476[info] [patched file /build/repo/core/src/test/scala/ox/MapParTest.scala]

477[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsFlattenTest.scala]

478[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsZipWithIndexTest.scala]

479[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsFoldTest.scala]

480[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsCollectTest.scala]

481[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsMapTest.scala]

482[info] [patched file /build/repo/core/src/test/scala/ox/CollectParTest.scala]

483[info] [patched file /build/repo/core/src/test/scala/ox/OxAppTest.scala]

484[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsFutureTest.scala]

485[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsDebounceTest.scala]

486[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsFilterTest.scala]

487[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsTakeWhileTest.scala]

488[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsThrottleTest.scala]

489[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsDropTest.scala]

490[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsSampleTest.scala]

491[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsEmptyTest.scala]

492[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsScanTest.scala]

493[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowCompanionIOOpsTest.scala]

494[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsMapUsingSinkTest.scala]

495[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsForeachTest.scala]

496[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsTimeoutTest.scala]

497[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsUsingSink.scala]

498[info] [patched file /build/repo/core/src/test/scala/ox/FilterParTest.scala]

499[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowIOOpsTest.scala]

500[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsZipAllTest.scala]

501[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsFlatMapTest.scala]

502[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsLastOptionTest.scala]

503[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsConcatPrependTest.scala]

504[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsLastTest.scala]

505[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsSplitOnTest.scala]

506[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsDebounceByTest.scala]

507[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsSplitTest.scala]

508[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsReduceTest.scala]

510[info] done compiling

511[info] compiling 33 Scala sources to /build/repo/core/target/scala-3.7.4/test-classes ...

525[info] done compiling

526Starting build for ProjectRef(file:/build/repo/,cron) (cron)... [3/6]

527Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.7-migration

528[info] compiling 1 Scala source to /build/repo/cron/target/scala-3.7.4/classes ...

529[info] done compiling

530[info] compiling 1 Scala source to /build/repo/cron/target/scala-3.7.4/test-classes ...

535[info] [patched file /build/repo/cron/src/test/scala/ox/scheduling/cron/CronScheduleTest.scala]

537[info] done compiling

538[info] compiling 1 Scala source to /build/repo/cron/target/scala-3.7.4/test-classes ...

539[info] done compiling

540Starting build for ProjectRef(file:/build/repo/,otelContext) (otel-context)... [4/6]

541Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.7-migration

542[info] compiling 1 Scala source to /build/repo/otel-context/target/scala-3.7.4/classes ...

543[info] done compiling

544Starting build for ProjectRef(file:/build/repo/,kafka) (kafka)... [5/6]

545Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.7-migration

546[info] compiling 9 Scala sources to /build/repo/kafka/target/scala-3.7.4/classes ...

555[info] [patched file /build/repo/kafka/src/main/scala/ox/kafka/kafkaOffsetCommit.scala]

556[info] [patched file /build/repo/kafka/src/main/scala/ox/kafka/KafkaFlow.scala]

557[info] [patched file /build/repo/kafka/src/main/scala/ox/kafka/KafkaStage.scala]

559[info] done compiling

560[info] compiling 3 Scala sources to /build/repo/kafka/target/scala-3.7.4/classes ...

561[info] done compiling

562[info] compiling 6 Scala sources to /build/repo/kafka/target/scala-3.7.4/test-classes ...

563[info] [patched file /build/repo/kafka/src/test/scala/ox/kafka/KafkaTest.scala]

564[info] done compiling

565[info] compiling 1 Scala source to /build/repo/kafka/target/scala-3.7.4/test-classes ...

566[info] done compiling

568************************

569Build summary:

570[{

571 "module": "flow-reactive-streams",

572 "compile": {"status": "ok", "tookMs": 16123, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

574 "test-compile": {"status": "ok", "tookMs": 6581, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

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

577 "metadata": {

578 "crossScalaVersions": ["2.12.20"]

579}

580},{

581 "module": "mdc-logback",

582 "compile": {"status": "ok", "tookMs": 469, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

584 "test-compile": {"status": "ok", "tookMs": 894, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

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

587 "metadata": {

588 "crossScalaVersions": ["2.12.20"]

589}

590},{

591 "module": "core",

592 "compile": {"status": "ok", "tookMs": 166, "warnings": 16, "errors": 0, "sourceVersion": "3.7-migration"},

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

594 "test-compile": {"status": "ok", "tookMs": 20853, "warnings": 49, "errors": 0, "sourceVersion": "3.7-migration"},

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

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

597 "metadata": {

598 "crossScalaVersions": ["2.12.20"]

599}

600},{

601 "module": "cron",

602 "compile": {"status": "ok", "tookMs": 418, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

604 "test-compile": {"status": "ok", "tookMs": 859, "warnings": 1, "errors": 0, "sourceVersion": "3.7-migration"},

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

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

607 "metadata": {

608 "crossScalaVersions": ["2.12.20"]

609}

610},{

611 "module": "otel-context",

612 "compile": {"status": "ok", "tookMs": 198, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

614 "test-compile": {"status": "ok", "tookMs": 145, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

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

617 "metadata": {

618 "crossScalaVersions": ["2.12.20"]

619}

620},{

621 "module": "kafka",

622 "compile": {"status": "ok", "tookMs": 777, "warnings": 2, "errors": 0, "sourceVersion": "3.7-migration"},

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

624 "test-compile": {"status": "ok", "tookMs": 1409, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

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

627 "metadata": {

628 "crossScalaVersions": ["2.12.20"]

629}

630}]

631************************

632[success] Total time: 63 s (0:01:03.0), completed Jan 8, 2026, 1:28:41 AM

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

634Checking patch build.sbt...

635Applied patch project/plugins.sbt cleanly.

636Applied patch build.sbt cleanly.

637Commit migration rewrites

638Switched to a new branch 'opencb/migrate-source-3.7'

639[opencb/migrate-source-3.7 8dd1e5e] Apply Scala compiler rewrites using -source:3.7-migration using Scala 3.7.4

640 43 files changed, 24 insertions(+), 60 deletions(-)

641----

642Preparing build for 3.8.0-RC6

643Scala binary version found: 3.8

644Implicitly using source version 3.8

645Scala binary version found: 3.8

646Implicitly using source version 3.8

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

648Append: ,REQUIRE:-source:3.8

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

650----

651Starting build for 3.8.0-RC6

652Execute tests: true

653sbt project found:

654No prepare script found for project softwaremill/ox

655##################################

656Scala version: 3.8.0-RC6

657Targets: com.softwaremill.ox%core com.softwaremill.ox%cron com.softwaremill.ox%flow-reactive-streams com.softwaremill.ox%kafka com.softwaremill.ox%mdc-logback com.softwaremill.ox%otel-context

658Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.7"],"sourcePatches":[]}

659##################################

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

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

662[sbt_options] declare -a sbt_options=()

663[process_args] java_version = '21'

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

665# Executing command line:

666java

667-Dfile.encoding=UTF-8

668-Dcommunitybuild.scala=3.8.0-RC6

669-Dcommunitybuild.project.dependencies.add=

670-Xmx7G

671-Xms4G

672-Xss8M

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

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

675-jar

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

677"setCrossScalaVersions 3.8.0-RC6"

678"++3.8.0-RC6 -v"

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

680"set every credentials := Nil"

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

682"removeScalacOptionsStartingWith -P:wartremover"

684moduleMappings

685"runBuild 3.8.0-RC6 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.7"],"sourcePatches":[]}""" com.softwaremill.ox%core com.softwaremill.ox%cron com.softwaremill.ox%flow-reactive-streams com.softwaremill.ox%kafka com.softwaremill.ox%mdc-logback com.softwaremill.ox%otel-context"

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

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

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

690[info] loading settings for project rootProject from build.sbt...

691[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.2)

692[info] set current project to ox (in build file:/build/repo/)

693Execute setCrossScalaVersions: 3.8.0-RC6

694OpenCB::Changing crossVersion 3.3.7 -> 3.8.0-RC6 in mdcLogback/crossScalaVersions

695OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0-RC6) in mdcLogback/crossScalaVersions

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

697OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0-RC6) in core/crossScalaVersions

698OpenCB::Changing crossVersion 3.3.7 -> 3.8.0-RC6 in flowReactiveStreams/crossScalaVersions

699OpenCB::Changing crossVersion 3.3.7 -> 3.8.0-RC6 in cron/crossScalaVersions

700OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0-RC6) in cron/crossScalaVersions

701OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0-RC6) in flowReactiveStreams/crossScalaVersions

702OpenCB::Changing crossVersion 3.3.7 -> 3.8.0-RC6 in documentation/crossScalaVersions

703OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0-RC6) in documentation/crossScalaVersions

704OpenCB::Changing crossVersion 3.3.7 -> 3.8.0-RC6 in rootProject/crossScalaVersions

705OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0-RC6) in rootProject/crossScalaVersions

706OpenCB::Changing crossVersion 3.3.7 -> 3.8.0-RC6 in otelContext/crossScalaVersions

707OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0-RC6) in otelContext/crossScalaVersions

708OpenCB::Changing crossVersion 3.3.7 -> 3.8.0-RC6 in kafka/crossScalaVersions

709OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0-RC6) in kafka/crossScalaVersions

710[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.2)

711[info] set current project to ox (in build file:/build/repo/)

712[info] Setting Scala version to 3.8.0-RC6 on 8 projects.

713[info] Switching Scala version on:

714[info] flowReactiveStreams (3.8.0-RC6)

715[info] documentation (3.8.0-RC6)

716[info] cron (3.8.0-RC6)

717[info] * rootProject (3.8.0-RC6)

718[info] mdcLogback (3.8.0-RC6)

719[info] kafka (3.8.0-RC6)

720[info] core (3.8.0-RC6)

721[info] otelContext (3.8.0-RC6)

722[info] Excluding projects:

723[info] Reapplying settings...

724[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.2)

725[info] set current project to ox (in build file:/build/repo/)

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

727[info] Reapplying settings...

728[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.2)

729[info] set current project to ox (in build file:/build/repo/)

730[info] Defining Global / credentials, core / credentials and 6 others.

731[info] The new values will be used by Compile / scalafmtOnly, Global / pgpSelectPassphrase and 63 others.

732[info] Run `last` for details.

733[info] Reapplying settings...

734[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.2)

735[info] set current project to ox (in build file:/build/repo/)

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

737[info] Reapplying settings...

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

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

741 Did you mean flowReactiveStreams / allExcludeDependencies ?

742 , retry without global scopes

743[info] Reapplying settings...

744[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.2)

745[info] set current project to ox (in build file:/build/repo/)

746Execute removeScalacOptionsStartingWith: -P:wartremover

747[info] Reapplying settings...

748[info] Not a M or RC version, using previous version for MiMa check: Some(1.0.2)

749[info] set current project to ox (in build file:/build/repo/)

750[success] Total time: 0 s, completed Jan 8, 2026, 1:28:52 AM

751Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"21"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.7"],"sourcePatches":[]}

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

753Starting build...

754Projects: Set(flowReactiveStreams, cron, mdcLogback, kafka, core, otelContext)

755Starting build for ProjectRef(file:/build/repo/,flowReactiveStreams) (flow-reactive-streams)... [0/6]

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

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

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

759Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

760[info] compiling 57 Scala sources to /build/repo/core/target/scala-3.8.0-RC6/classes ...

820[info] done compiling

821[info] compiling 1 Scala source to /build/repo/flow-reactive-streams/target/scala-3.8.0-RC6/classes ...

822[info] done compiling

823Starting build for ProjectRef(file:/build/repo/,mdcLogback) (mdc-logback)... [1/6]

824Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

825[info] compiling 1 Scala source to /build/repo/mdc-logback/target/scala-3.8.0-RC6/classes ...

826[info] done compiling

827[info] compiling 1 Scala source to /build/repo/mdc-logback/target/scala-3.8.0-RC6/test-classes ...

828[info] done compiling

82901:29:16.014 [pool-28-thread-7] INFO ox.logback.InheritableMDC$ -- Scoped-value based MDC initialized

830[info] InheritableMDCTest:

831[info] - should make MDC values available in forks

832Starting build for ProjectRef(file:/build/repo/,core) (core)... [2/6]

833Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

834[info] compiling 112 Scala sources to /build/repo/core/target/scala-3.8.0-RC6/test-classes ...

916[info] done compiling

917[info] AfterAttemptTest:

918[info] RetryPolicy afterAttempt callback

919[info] - should retry a succeeding function with afterAttempt callback

920[info] - should retry a failing function with afterAttempt callback

921[info] SourceOpsTest:

922[info] - should pipe one source to another

923[info] - should pipe one source to another (with done propagation)

924[info] - should tap over a source

925[info] FlowOpsReduceTest:

926[info] reduce

929[info] - should return first element from reduce over the single element source

930[info] - should run reduce over on non-empty source

932[info] unsupervised

935[info] supervised

950[info] joinEither

952[info] ScheduleFallingBackRetryTest:

953[info] retry with combination of schedules

954[info] - should retry 3 times immediately and then 2 times with delay

955[info] - should retry forever

956[info] DelayedRetryTest:

957[info] Delayed retry

958[info] - should retry a function

959[info] - should retry a failing function forever

960[info] - should retry an Either

961[info] adaptive retry with delayed config

962[info] - should retry a failing function forever or until adaptive retry blocks it

963[info] CircuitBreakerTest:

964[info] Circuit Breaker run operations

965[info] - should run operation when metrics are not exceeded

966[info] - should drop operation after exceeding failure threshold

967[info] - should drop operation after exceeding slow call threshold

968[info] Circuit Breaker scheduled state changes

969[info] - should switch to halfOpen after configured time

970[info] - should switch back to open after configured timeout in half open state

971[info] - should correctly transitions through states when there are concurrently running operations

972[info] - should correctly calculate metrics when results come in after state change

973[info] FlowOpsTakeWhileTest:

974[info] takeWhile

975[info] - should not take from the empty flow

976[info] - should take as long as predicate is satisfied

977[info] - should take the failed element if includeFirstFailing = true

978[info] - should work if all elements match the predicate

980[info] - should not take if predicate fails for first or more elements

981[info] FlowOpsInterleaveAllTest:

982[info] interleaveAll

983[info] - should interleave no sources

984[info] - should interleave a single flow

985[info] - should interleave multiple flows

986[info] - should interleave multiple flows using custom segment size

987[info] - should interleave multiple flows using custom segment size and complete eagerly

988[info] AppErrorTest:

989[info] supervisedError

990[info] - should return the app error from the main body

991[info] - should return success from the main body

992[info] - should return the app error returned by a failing fork

993[info] - should return success from the main body if a fork is successful

994[info] - should interrupt other forks if one fails

995[info] ChunkTest:

996[info] Chunk

997[info] - should create empty chunks

998[info] - should create chunks from arrays

999[info] - should create chunks from IArrays

1000[info] - should create chunks from elements

1001[info] - should create empty chunks from empty arrays

1002[info] - should support random access

1004[info] - should support iteration

1005[info] - should support foreach operations

1006[info] - should concatenate two non-empty chunks efficiently

1007[info] - should handle concatenation with empty chunks

1008[info] - should support chained concatenation

1009[info] - should concatenate chunks of different types

1010[info] - should concatenate non-empty chunk with non-chunk collections

1011[info] - should concatenate empty chunk with non-chunk collections

1012[info] - should handle concatenation with empty collections

1013[info] - should support drop operations

1014[info] - should support take operations

1015[info] - should handle drop/take on concatenated chunks

1016[info] - should support map operations

1017[info] - should support filter operations

1018[info] - should support collect operations

1019[info] - should convert to arrays correctly

1020[info] - should convert concatenated chunks to arrays correctly

1021[info] - should convert byte chunks to strings

1022[info] - should convert concatenated byte chunks to strings

1023[info] - should provide access to backing arrays

1024[info] - should allow efficient processing via backing arrays

1025[info] - should handle operations on empty chunks

1026[info] - should maintain consistency between single and multi-array chunks

1027[info] - should handle large chunks efficiently

1028[info] - should support indexWhere on single chunks

1029[info] - should support indexWhere on concatenated chunks

1030[info] - should handle indexWhere on empty chunks

1031[info] - should handle indexWhere edge cases with concatenated chunks

1032[info] - should support contains and exists operations

1033[info] FlowOpsFoldTest:

1034[info] fold

1037[info] - should return `zero` value from fold on the empty source

1038[info] - should return fold on non-empty fold

1039[info] FlowOpsFilterTest:

1040[info] filter

1041[info] - should not filter anything from the empty flow

1042[info] - should filter out everything if no element meets 'f'

1043[info] - should not filter anything if all the elements meet 'f'

1044[info] - should filter out elements that don't meet 'f'

1045[info] FlowOpsMapUsingSinkTest:

1046[info] mapUsingSink

1047[info] - should map over a source, using emit

1048[info] - should propagate errors

1049[info] FlowOpsCollectTest:

1050[info] collect

1051[info] - should collect over a source

1052[info] FlowOpsGroupedTest:

1053[info] grouped

1054[info] - should emit grouped elements

1055[info] - should emit grouped elements and include remaining values when flow closes

1056[info] - should return failed flow when the original flow is failed

1057[info] groupedWeighted

1058[info] - should emit grouped elements with custom cost function

1060[info] - should return failed source when the original source is failed

1061[info] groupedWithin

1062[info] - should group first batch of elements due to limit and second batch due to timeout

1063[info] - should group first batch of elements due to timeout and second batch due to limit

1064[info] - should wake up on new element and send it immediately after first batch is sent and channel goes to time-out mode

1065[info] - should send the group only once when the channel is closed

1066[info] - should return failed source when the original source is failed

1067[info] groupedWeightedWithin

1068[info] - should group elements on timeout in the first batch and consider max weight in the remaining batches

1070[info] - should return failed source when the original source is failed

1071[info] MapParTest:

1072[info] mapPar

1073[info] - should output the same type as input

1074[info] - should run computations in parallel

1075[info] - should run not more computations than limit

1077[2026-01-08T00:30:01.152795537Z] [24] catch

1078[2026-01-08T00:30:01.453016337Z] [24] all done

1079[info] - should interrupt other computations in one fails

1080[info] RateLimiterInterfaceTest:

1081[info] RateLimiter interface

1082[info] - should drop or block operation depending on method used for fixed rate algorithm

1083[info] - should drop or block operation depending on method used for sliding window algorithm

1084[info] - should drop or block operation depending on method used for bucket algorithm

1085[info] - should drop or block operation concurrently

1086[info] UtilTest:

1087[info] discard

1088[2026-01-08T00:30:07.482480271Z] [24] in f

1089[info] - should do nothing

1091[2026-01-08T00:30:07.483619812Z] [24] in callback: boom!

1092[2026-01-08T00:30:07.483783818Z] [24] in catch: boom!

1093[2026-01-08T00:30:07.484445349Z] [24] 42

1094[2026-01-08T00:30:07.484515490Z] [24] after

1095[2026-01-08T00:30:07.487333827Z] [24] in catch: boom! 1

1099[info] pipe

1100[info] - should work

1101[info] tap

1102[2026-01-08T00:30:07.488868154Z] [24] Adding

1103[2026-01-08T00:30:07.489966940Z] [24] Got: 3

1104[info] - should work

1105[info] debug as extension

1106some label: 10

1107[info] - should work

1108[info] debug as top-level method

1109x.+(1) = 11

1110[info] - should work

1111[info] FlowOpsLastTest:

1112[info] last

1115[info] - should return last element for the non-empty source

1116[info] FlowOpsFailedTest:

1117[info] failed

1118[info] - should fail on receive

1119[info] FlowOpsFlattenTest:

1120[info] flatten

1121[info] - should flatten nested flows

1122[info] WeightedHeapTest:

1123[info] WeightedHeap

1124[info] - should allow inserting elements with weights

1125[info] - should allow extracting the minimum element

1126[info] - should return None when extracting from an empty heap

1127[info] - should return the correct size after operations

1128[info] - should handle empty heaps correctly

1129[info] - should update the weight of an existing element and adjust its position

1131[info] - should handle multiple insertions and updates correctly

1132[info] - should handle duplicate insertions by updating the existing element's weight

1133[info] - should handle increasing the weight of an existing element

1134[info] - should maintain heap property after multiple weight increases

1135[info] - should work correctly when increasing the weight of the current minimum element

1136[info] - should handle increasing weights in a large heap

1137[info] - should maintain the heap property after multiple operations

1138[info] - should work with large numbers of elements

1139[info] - should maintain heap property with random insertions and extractions

1140[info] - should maintain heap property with random weight updates

1141[info] FlowOpsMapConcatTest:

1142[info] mapConcat

1143[info] - should unfold iterables

1144[info] - should transform elements

1145[info] - should handle empty lists

1146[info] - should propagate errors in the mapping function

1147[info] FlowOpsPipeToTest:

1148[info] - should pipe one source to another

1149[info] - should pipe one source to another (with done propagation)

1150[info] FlowOpsRecoverTest:

1151[info] Flow.recover

1152[info] - should pass through elements when upstream flow succeeds

1157[info] - should work with different recovery value type

1159[info] - should work with empty flow

1161[info] FlowOpsMapStatefulTest:

1162[info] mapStateful

1163[info] - should zip with index

1164[info] - should calculate a running total

1165[info] - should be able to emit different values than incoming ones

1166[info] - should propagate errors in the mapping function

1167[info] - should propagate errors in the completion callback

1168[info] FlowOpsMapTest:

1169[info] map

1170[info] - should map over a source

1171[info] - should map over a source using for-syntax

1172[info] ForkTest:

1173[2026-01-08T00:30:07.691613795Z] [24] main mid

1174[info] fork

1175[2026-01-08T00:30:08.191987488Z] [435] f1 complete

1176[2026-01-08T00:30:08.692068497Z] [436] f2 complete

1177[2026-01-08T00:30:08.692511392Z] [24] result = 11

1178[info] - should run two forks concurrently

1179[2026-01-08T00:30:08.695583990Z] [438] f2 complete

1180[2026-01-08T00:30:08.695746122Z] [437] f1 complete

1181[2026-01-08T00:30:08.696200761Z] [24] result = 11

1182[info] - should allow nested forks

1183[2026-01-08T00:30:08.697613752Z] [24] main mid

1184[2026-01-08T00:30:09.198180324Z] [439] f1 complete

1185[2026-01-08T00:30:09.198523076Z] [24] result = 5

1186[2026-01-08T00:30:09.198964635Z] [440] f2 interrupted

1187[info] - should interrupt child forks when parents complete

1188[2026-01-08T00:30:09.202101225Z] [444] in fork

1189[info] - should allow starting forks within a forkCancellable body, using the outer scope

1190[2026-01-08T00:30:09.303524648Z] [447] in fork

1191[info] - should allow starting forks in outer scope, from an inner scope

1193[info] - should not allow starting forks from a thread created not by the scope

1194[info] FlowOpsIntersperseTest:

1195[info] Flow.intersperse

1196[info] - should intersperse with inject only over an empty source

1197[info] - should intersperse with inject only over a source with one element

1198[info] - should intersperse with inject only over a source with multiple elements

1199[info] - should intersperse with start, inject and end over an empty source

1200[info] - should intersperse with start, inject and end over a source with one element

1201[info] - should intersperse with start, inject and end over a source with multiple elements

1202[info] FlowOpsScanTest:

1203[info] scan

1204[info] - should scan the empty flow

1205[info] - should scan a flow of summed Int

1206[info] - should scan a flow of multiplied Int

1207[info] - should scan a flow of concatenated String

1208[info] FlowOpsUsingSinkTest:

1209[info] usingSink

1210[info] - should send the passed elements

1211[info] FlowOpsTakeTest:

1212[info] take

1213[info] - should take from a simple flow

1214[info] - should take from an async flow

1215[info] - should take all if the flow ends sooner than the desired number of elements

1216[info] EitherTest:

1217[info] either

1218[info] - should work correctly when invoked on eithers

1219[info] - should work correctly when invoked on options

1220[info] - should work correctly when invoked on fork

1221[info] - should report a proper compilation error when used outside of either:

1222[info] - should report a proper compilation error when wrong error type is used for ok() (explicit type params)

1223[info] - should report a proper compilation error when wrong successful type is used (explicit type params)

1224[info] - should report a proper compilation error when wrong type annotation is used for ok() (error)

1225[info] - should report a proper compilation error when wrong type annotation is used (success)

1226[info] - should report a proper compilation error when wrong error type is used for fail() (explicit type params)

1227[info] - should report a proper compilation error when wrong type annotation is used for fail() (error)

1231[info] - should report a proper compilation error when wrong error type is used for ok() in catchingNonFatal block

1232[info] - should work when combined with mapPar

1233[info] - should not allow nesting of eithers

1234[info] orThrow

1235[info] - should unwrap the value for a Right-value

1237[info] catching

1242[info] - should return successful results as Right-values

1243[info] FlowIOOpsTest:

1244[info] asInputStream

1245[info] - should return an empty InputStream for an empty source

1246[info] - should return an InputStream for a simple source

1247[info] - should correctly track available bytes

1248[info] - should support bulk read operations with read(byte[])

1249[info] - should handle bulk read operations across multiple chunks

1250[info] - should handle bulk read with concatenated chunks (multiple backing arrays)

1251[info] - should handle read(byte[], offset, length) with various parameters

1252[info] - should handle edge cases for read(byte[], offset, length)

1254[info] - should maintain consistency between single-byte and bulk reads

1255[info] - should handle chunks with empty backing arrays

1256[info] - should handle flow with only empty chunks

1257[info] - should handle mixed empty and non-empty chunks in flow

1258[info] toOutputStream

1259[info] - should write a single chunk with bytes to an OutputStream

1260[info] - should write multiple chunks with bytes to an OutputStream

1261[info] - should write concatenated chunks to an OutputStream

1262[info] - should handle an empty Source

1263[info] - should close the OutputStream on write error

1264[info] - should close the OutputStream on error

1265[info] toFile

1266[info] - should open existing file and write a single chunk with bytes

1267[info] - should open existing file and write multiple chunks with bytes

1268[info] - should create file and write multiple chunks with bytes

1269[info] - should write concatenated chunks to a file

1270[info] - should use an existing file and overwrite it a single chunk with bytes

1271[info] - should handle an empty source

1275[info] FlowOpsConcatPrependTest:

1276[info] concat

1277[info] - should concat other source

1278[info] prepend

1279[info] - should prepend other source

1280[info] FlowTextOpsTest:

1281[info] linesUtf8

1282[info] - should split a single chunk of bytes into lines

1283[info] - should split a single chunk of bytes into lines (multiple newlines)

1284[info] - should split a single chunk of bytes into lines (beginning with newline)

1285[info] - should split a single chunk of bytes into lines (ending with newline)

1286[info] - should split a single chunk of bytes into lines (empty array)

1287[info] - should split a multiple chunks of bytes into lines

1288[info] - should split a multiple chunks of bytes into lines (multiple newlines)

1289[info] - should split a multiple chunks of bytes into lines (multiple empty chunks)

1290[info] lines(charset)

1291zażółć

1292gęślą

1293jaźń

1294[info] - should decode lines with specified charset

1295[info] - should decode lines correctly across chunk boundaries

1296[info] decodeStringUtf8

1297[info] - should decode a simple string

1298[info] - should decode a chunked string with UTF-8 multi-byte characters

1299[info] - should handle an empty Source

1300[info] - should handle partial BOM

1301[info] - should handle a string shorter than BOM

1302[info] - should handle empty chunks

1303[info] encodeUtf8

1304[info] - should handle empty String

1305[info] - should encode a string

1306[info] FlowOpsZipWithIndexTest:

1307[info] zipWithIndex

1308[info] - should not zip anything from an empty flow

1309[info] - should zip flow with index

1310[info] ResourceTest:

1311[info] useInScope

1312[2026-01-08T00:30:09.558667252Z] [24] allocate

1313[2026-01-08T00:30:09.559497420Z] [550] release 1

1314[info] - should release resources after allocation

1315[2026-01-08T00:30:09.561266663Z] [24] allocate 1

1316[2026-01-08T00:30:09.561770561Z] [24] allocate 2

1317[2026-01-08T00:30:09.563092353Z] [551] release 2

1318[2026-01-08T00:30:09.563265896Z] [551] release 1

1319[info] - should release resources in reverse order

1320[2026-01-08T00:30:09.565531116Z] [24] allocate 1

1321[2026-01-08T00:30:09.566013945Z] [24] allocate 2

1322[2026-01-08T00:30:09.566578113Z] [552] release 2

1323[2026-01-08T00:30:09.566697395Z] [552] release 1

1326[2026-01-08T00:30:09.568392473Z] [24] allocate 1

1327[2026-01-08T00:30:09.568851896Z] [24] allocate 2

1328[2026-01-08T00:30:09.569412673Z] [553] release 2

1329[2026-01-08T00:30:09.569775516Z] [553] release 1

1332[2026-01-08T00:30:09.571355390Z] [24] allocate 1

1333[2026-01-08T00:30:09.572191938Z] [24] allocate 2

1334[2026-01-08T00:30:09.572719159Z] [554] release 2

1335[2026-01-08T00:30:09.572854631Z] [554] release 1

1338[2026-01-08T00:30:09.575334916Z] [24] in scope

1339[2026-01-08T00:30:09.575649833Z] [555] release

1340[info] - should release registered resources

1341[2026-01-08T00:30:09.576690781Z] [24] allocate

1342[2026-01-08T00:30:09.576789575Z] [24] in scope

1343[2026-01-08T00:30:09.577781221Z] [556] release

1344[info] - should use a resource

1345[2026-01-08T00:30:09.579173643Z] [24] allocate

1346[2026-01-08T00:30:09.579244906Z] [24] in scope

1347[2026-01-08T00:30:09.579859861Z] [557] release

1348[info] - should use a closeable resource

1349[2026-01-08T00:30:09.581682935Z] [24] allocate

1350[2026-01-08T00:30:09.581784455Z] [24] in scope

1351[2026-01-08T00:30:09.582966719Z] [558] release

1354[info] FlowOpsMapParTest:

1355[info] mapPar

1356[info] - should map over a flow with parallelism limit 1

1357[info] - should map over a flow with parallelism limit 2

1358[info] - should map over a flow with parallelism limit 3

1359[info] - should map over a flow with parallelism limit 4

1360[info] - should map over a flow with parallelism limit 5

1361[info] - should map over a flow with parallelism limit 6

1362[info] - should map over a flow with parallelism limit 7

1363[info] - should map over a flow with parallelism limit 8

1364[info] - should map over a flow with parallelism limit 9

1365[info] - should map over a flow with parallelism limit 10

1366[info] - should map over a flow with parallelism limit 10 (stress test)

1367[info] + iteration 1

1368[info] + iteration 2

1369[info] + iteration 3

1370[info] + iteration 4

1371[info] + iteration 5

1372[info] + iteration 6

1373[info] + iteration 7

1374[info] + iteration 8

1375[info] + iteration 9

1376[info] + iteration 10

1377[info] + iteration 11

1378[info] + iteration 12

1379[info] + iteration 13

1380[info] + iteration 14

1381[info] + iteration 15

1382[info] + iteration 16

1383[info] + iteration 17

1384[info] + iteration 18

1385[info] + iteration 19

1386[info] + iteration 20

1387[info] + iteration 21

1388[info] + iteration 22

1389[info] + iteration 23

1390[info] + iteration 24

1391[info] + iteration 25

1392[info] + iteration 26

1393[info] + iteration 27

1394[info] + iteration 28

1395[info] + iteration 29

1396[info] + iteration 30

1397[info] + iteration 31

1398[info] + iteration 32

1399[info] + iteration 33

1400[info] + iteration 34

1401[info] + iteration 35

1402[info] + iteration 36

1403[info] + iteration 37

1404[info] + iteration 38

1405[info] + iteration 39

1406[info] + iteration 40

1407[info] + iteration 41

1408[info] + iteration 42

1409[info] + iteration 43

1410[info] + iteration 44

1411[info] + iteration 45

1412[info] + iteration 46

1413[info] + iteration 47

1414[info] + iteration 48

1415[info] + iteration 49

1416[info] + iteration 50

1417[info] + iteration 51

1418[info] + iteration 52

1419[info] + iteration 53

1420[info] + iteration 54

1421[info] + iteration 55

1422[info] + iteration 56

1423[info] + iteration 57

1424[info] + iteration 58

1425[info] + iteration 59

1426[info] + iteration 60

1427[info] + iteration 61

1428[info] + iteration 62

1429[info] + iteration 63

1430[info] + iteration 64

1431[info] + iteration 65

1432[info] + iteration 66

1433[info] + iteration 67

1434[info] + iteration 68

1435[info] + iteration 69

1436[info] + iteration 70

1437[info] + iteration 71

1438[info] + iteration 72

1439[info] + iteration 73

1440[info] + iteration 74

1441[info] + iteration 75

1442[info] + iteration 76

1443[info] + iteration 77

1444[info] + iteration 78

1445[info] + iteration 79

1446[info] + iteration 80

1447[info] + iteration 81

1448[info] + iteration 82

1449[info] + iteration 83

1450[info] + iteration 84

1451[info] + iteration 85

1452[info] + iteration 86

1453[info] + iteration 87

1454[info] + iteration 88

1455[info] + iteration 89

1456[info] + iteration 90

1457[info] + iteration 91

1458[info] + iteration 92

1459[info] + iteration 93

1460[info] + iteration 94

1461[info] + iteration 95

1462[info] + iteration 96

1463[info] + iteration 97

1464[info] + iteration 98

1465[info] + iteration 99

1466[info] + iteration 100

1467[info] - should propagate errors

1468[2026-01-08T00:30:18.212907268Z] [1916] done

1469[2026-01-08T00:30:18.212907237Z] [1917] done

1471[info] - should cancel other running forks when there's an error

1472[info] - should handle empty flow

1473[info] - should handle flow with exactly parallelism number of elements

1474[info] - should handle flow with less than parallelism number of elements

1475[info] - should preserve order even with varying processing times

1476[info] - should preserve order with random processing times

1477[info] - should work with very high parallelism values

1478[info] SelectOrClosedWithinTest:

1479[info] selectOrClosedWithin

1480[info] - should select a clause that can complete immediately

1481[info] - should return timeout when no clause can complete within the timeout

1482[info] - should select a source that has a value immediately

1483[info] - should return timeout when no source has a value within the timeout

1484[info] - should work with different timeout value types

1485[info] - should handle empty clauses sequence

1486[info] - should handle empty sources sequence

1487[info] selectOrClosedWithin with single clause

1488[info] - should complete when clause is ready

1489[info] - should timeout when clause is not ready

1490[info] selectOrClosedWithin with multiple clauses

1491[info] - should select the first ready clause

1492[info] - should timeout when no clauses are ready

1493[info] selectOrClosedWithin with sources

1494[info] - should select from ready source

1495[info] - should timeout when no sources are ready

1496[info] selectOrClosedWithin error scenarios

1497[info] - should handle channel closed with done

1498[info] - should handle channel closed with error

1499[info] - should prioritize ready channels over closed ones

1500[info] selectOrClosedWithin with different timeout types

1501[info] - should work with various timeout value types

1502[info] selectOrClosedWithin with sequences

1503[info] - should handle empty sequences

1504[info] - should handle sequence of clauses

1505[info] - should handle sequence of sources

1506[info] selectOrClosedWithin with various arities

1507[info] - should work with all supported clause counts

1508[info] - should work with all supported source counts

1509[info] FlowOpsSplitTest:

1510[info] split

1511[info] - should split an empty flow

1512[info] - should split a flow with no delimiters

1513[info] - should split a flow with delimiter at the beginning

1514[info] - should split a flow with delimiter at the end

1515[info] - should split a flow with delimiter in the middle

1516[info] - should split a flow with multiple delimiters

1517[info] - should split a flow with adjacent delimiters

1518[info] - should split a flow with only delimiters

1519[info] - should split a flow with single delimiter

1520[info] - should split a flow with single non-delimiter

1521[info] - should split a flow with multiple consecutive delimiters at the beginning

1522[info] - should split a flow with multiple consecutive delimiters at the end

1523[info] - should split a flow with string delimiters

1524[info] - should split a flow using complex predicate

1525[info] - should handle error propagation

1526[info] - should split a large flow efficiently

1527[info] JitterTest:

1528[info] Jitter

1529[info] - should use no jitter

1530[info] - should use full jitter

1531[info] - should use equal jitter

1532[info] - should use decorrelated jitter

1533[info] FlowOpsAlsoToTest:

1534[info] alsoTo

1535[info] - should send to both sinks

1536[info] - should send to both sinks and not hang when other sink is rendezvous channel

1537[info] - should close main flow when other closes

1538[info] - should close main flow with error when other errors

1539[info] - should close other channel with error when main errors

1540[info] FlowOpsBufferTest:

1541[info] buffer

1542[info] - should work with a single async boundary

1543[info] - should work with multiple async boundaries

1544[info] - should propagate errors

1545[info] BackoffRetryTest:

1546[info] Backoff retry

1547[info] - should retry a function

1548[info] - should retry a failing function forever

1549[info] - should respect maximum delay

1550[info] - should use jitter

1551[info] - should retry an Either

1552[info] FlowOpsEnsureTest:

1553[info] ensure.onComplete

1554[info] - should run in case of success

1555[info] - should run in case of error

1556[info] ensure.onDone

1557[info] - should run in case of success

1558[info] - should not run in case of error

1559[info] ensure.onError

1560[info] - should not run in case of success

1561[info] - should run in case of error

1562[info] FlowOpsTakeLastTest:

1563[info] takeLast

1565[info] - should fail to takeLast when n < 0

1566[info] - should return empty list for the empty source

1567[info] - should return empty list when n == 0 and list is not empty

1568[info] - should return list with all elements if the source is smaller than requested number

1569[info] - should return the last n elements from the source

1570[info] FlowOpsZipAllTest:

1571[info] zipAll

1572[info] - should not emit any element when both flows are empty

1573[info] - should emit this element when other flow is empty

1574[info] - should emit other element when this flow is empty

1575[info] - should emit matching elements when both flows are of the same size

1576[info] - should emit default for other flow if this flow is longer

1577[info] - should emit default for this flow if other flow is longer

1578[info] FlowPublisherTckTest:

1579[info] - required_createPublisher1MustProduceAStreamOfExactly1Element

1580[info] - required_createPublisher3MustProduceAStreamOfExactly3Elements

1581[info] - required_validate_maxElementsFromPublisher

1582[info] - required_validate_boundedDepthOfOnNextAndRequestRecursion

1583[info] - required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements

1584[info] - required_spec102_maySignalLessThanRequestedAndTerminateSubscription

1585[info] - stochastic_spec103_mustSignalOnMethodsSequentially

1586[info] - optional_spec104_mustSignalOnErrorWhenFails

1587[info] - required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates

1588[info] - optional_spec105_emptyStreamMustTerminateBySignallingOnComplete

1589[info] - required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled

1590[info] - untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled !!! IGNORED !!!

1591[info] - untested_spec109_subscribeShouldNotThrowNonFatalThrowable !!! IGNORED !!!

1592[info] - required_spec109_subscribeThrowNPEOnNullSubscriber

1593[info] - required_spec109_mustIssueOnSubscribeForNonNullSubscriber

1594[info] - required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe

1595[info] - untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice !!! IGNORED !!!

1596[info] - optional_spec111_maySupportMultiSubscribe

1597[info] - optional_spec111_registeredSubscribersMustReceiveOnNextOrOnCompleteSignals

1598[info] - optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne

1599[info] - optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront

1600[info] - optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected

1601[info] - required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe

1602[info] - required_spec303_mustNotAllowUnboundedRecursion

1603[info] - untested_spec304_requestShouldNotPerformHeavyComputations !!! IGNORED !!!

1604[info] - untested_spec305_cancelMustNotSynchronouslyPerformHeavyComputation !!! IGNORED !!!

1605[info] - required_spec306_afterSubscriptionIsCancelledRequestMustBeNops

1606[info] - required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops

1609[info] - required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling

1610[info] - required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber

1611[info] - required_spec317_mustSupportAPendingElementCountUpToLongMaxValue

1612[info] - required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue

1613[info] - required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue

1615[info] - untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals !!! IGNORED !!!

1616[info] - untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled !!! IGNORED !!!

1617[info] SourceOpsFactoryMethodsTest:

1618[info] Source factory methods

1619[info] - should create a source from a fork

1620[info] CancelTest:

1621[info] cancel

1622[2026-01-08T00:30:26.552984038Z] [2410] started

1623[2026-01-08T00:30:26.653395570Z] [2410] interrupted

1624[2026-01-08T00:30:27.153878745Z] [2410] interrupted done

1625[2026-01-08T00:30:27.154214638Z] [2408] cancel done

1626[info] - should block until the fork completes

1627[2026-01-08T00:30:28.157367548Z] [2411] cancel done

1628[2026-01-08T00:30:28.259368821Z] [2416] interrupted

1629[2026-01-08T00:30:28.359764415Z] [2416] interrupted done

1630[2026-01-08T00:30:28.360038173Z] [2414] cancel done

1631[2026-01-08T00:30:28.460707394Z] [2417] cancel done

1632[2026-01-08T00:30:28.562656427Z] [2422] interrupted

1633[2026-01-08T00:30:28.663003650Z] [2422] interrupted done

1634[2026-01-08T00:30:28.663216Z] [2420] cancel done

1635[2026-01-08T00:30:28.763968178Z] [2423] cancel done

1636[2026-01-08T00:30:28.865897587Z] [2428] interrupted

1637[2026-01-08T00:30:28.966276489Z] [2428] interrupted done

1638[2026-01-08T00:30:28.966570889Z] [2426] cancel done

1639[2026-01-08T00:30:29.067290895Z] [2429] cancel done

1640[2026-01-08T00:30:29.169236375Z] [2434] interrupted

1641[2026-01-08T00:30:29.269681922Z] [2434] interrupted done

1642[2026-01-08T00:30:29.269942850Z] [2432] cancel done

1643[2026-01-08T00:30:29.370585021Z] [2435] cancel done

1644[2026-01-08T00:30:29.472501784Z] [2440] interrupted

1645[2026-01-08T00:30:29.572887821Z] [2440] interrupted done

1646[2026-01-08T00:30:29.573130324Z] [2438] cancel done

1647[2026-01-08T00:30:29.673791982Z] [2441] cancel done

1648[2026-01-08T00:30:29.775713118Z] [2446] interrupted

1649[2026-01-08T00:30:29.876036505Z] [2446] interrupted done

1650[2026-01-08T00:30:29.876234494Z] [2444] cancel done

1651[2026-01-08T00:30:29.976748115Z] [2447] cancel done

1652[2026-01-08T00:30:30.078596806Z] [2452] interrupted

1653[2026-01-08T00:30:30.178978585Z] [2452] interrupted done

1654[2026-01-08T00:30:30.179207058Z] [2450] cancel done

1655[2026-01-08T00:30:30.279851655Z] [2453] cancel done

1656[2026-01-08T00:30:30.381862085Z] [2458] interrupted

1657[2026-01-08T00:30:30.482245175Z] [2458] interrupted done

1658[2026-01-08T00:30:30.482539635Z] [2456] cancel done

1659[2026-01-08T00:30:30.583180245Z] [2459] cancel done

1660[2026-01-08T00:30:30.685187547Z] [2464] interrupted

1661[2026-01-08T00:30:30.785645507Z] [2464] interrupted done

1662[2026-01-08T00:30:30.785912506Z] [2462] cancel done

1663[2026-01-08T00:30:30.886591064Z] [2465] cancel done

1664[2026-01-08T00:30:30.988376598Z] [2470] interrupted

1665[2026-01-08T00:30:31.088755140Z] [2470] interrupted done

1666[2026-01-08T00:30:31.089020111Z] [2468] cancel done

1667[info] - should block until the fork completes (stress test)

1668[info] + iteration 1

1669[info] + iteration 2

1670[info] + iteration 3

1671[info] + iteration 4

1672[info] + iteration 5

1673[info] + iteration 6

1674[info] + iteration 7

1675[info] + iteration 8

1676[info] + iteration 9

1677[info] + iteration 10

1678[info] + iteration 11

1679[info] + iteration 12

1680[info] + iteration 13

1681[info] + iteration 14

1682[info] + iteration 15

1683[info] + iteration 16

1684[info] + iteration 17

1685[info] + iteration 18

1686[info] + iteration 19

1687[info] + iteration 20

1688[info] cancelNow

1689[2026-01-08T00:30:31.292488348Z] [2471] cancel done

1690[2026-01-08T00:30:31.792858434Z] [2473] interrupted done

1691[info] - should return immediately, and wait for forks when scope completes

1693[info] FlowOpsTapTest:

1694[info] - should tap over a flow

1695[info] FlowOpsAlsoToTapTest:

1696[info] alsoToTap

1697[info] - should send to both sinks when other is faster

1698[info] - should send to both sinks when other is slower

1699[info] - should not fail the flow when the other sink fails

1700[info] - should not close the flow when the other sink closes

1701[info] SourceOpsFailedTest:

1702[info] Source.failed

1703[info] - should fail on receive

1704[info] - should be in error

1705[info] FlowOpsDebounceTest:

1706[info] debounce

1707[info] - should not debounce if applied on an empty flow

1708[info] - should not debounce if applied on a flow containing only distinct values

1709[info] - should debounce if applied on a flow containing only repeating values

1710[info] - should debounce if applied on a flow containing repeating elements

1711[info] FlowOpsThrottleTest:

1712[info] throttle

1713[info] - should not throttle the empty source

1714[info] - should throttle to specified elements per time units

1715[info] - should fail to throttle when elements <= 0

1716[info] - should fail to throttle when per lower than 1ms

1717[info] FlowOpsRunToChannelTest:

1718[info] runToChannel

1719[info] - should receive the elements in the flow

1720[info] - should return the original source when running a source-backed flow

1721[info] FlowOpsTimeoutTest:

1722[info] - should timeout

1723[info] FlowOpsZipTest:

1724[info] - should zip two sources

1725[info] FixedRateRepeatTest:

1726[info] repeat

1727[info] - should repeat a function at fixed rate

1728[info] - should repeat a function at fixed rate with initial delay

1729[info] - should repeat a function forever at fixed rate

1730[info] - should repeat a function forever at fixed rate with initial delay

1731[info] ForeachParTest:

1732[info] foreachPar

1733[2026-01-08T00:30:33.931518176Z] [2505] 3

1734[2026-01-08T00:30:33.931510667Z] [2502] 0

1735[2026-01-08T00:30:33.931510628Z] [2506] 4

1736[2026-01-08T00:30:33.931510689Z] [2504] 2

1737[2026-01-08T00:30:33.931632293Z] [2503] 1

1738[2026-01-08T00:30:34.032198535Z] [2509] 7

1739[2026-01-08T00:30:34.032186154Z] [2508] 6

1740[2026-01-08T00:30:34.032251804Z] [2511] 9

1741[2026-01-08T00:30:34.032245219Z] [2510] 8

1742[2026-01-08T00:30:34.032397573Z] [2507] 5

1743[2026-01-08T00:30:34.132698799Z] [2512] 10

1744[2026-01-08T00:30:34.132747110Z] [2513] 11

1745[2026-01-08T00:30:34.132781997Z] [2514] 12

1746[2026-01-08T00:30:34.132835237Z] [2515] 13

1747[2026-01-08T00:30:34.132833831Z] [2516] 14

1748[2026-01-08T00:30:34.233248470Z] [2517] 15

1749[2026-01-08T00:30:34.233419126Z] [2518] 16

1750[2026-01-08T00:30:34.233438837Z] [2519] 17

1751[info] - should run computations in parallel

1752[info] - should run not more computations than limit

1754[2026-01-08T00:30:34.569425652Z] [24] catch

1755[2026-01-08T00:30:34.869628564Z] [24] all done

1756[info] - should interrupt other computations in one fails

1757[info] FlowOpsFutureSourceTest:

1758[info] futureSource

1759[info] - should return the original future failure when future fails

1760[info] - should return future's source values

1761[info] SourceOpsTransformTest:

1762[info] Source.transform

1763[info] - should transform a source using a simple map

1764[info] - should transform a source using a complex chain of operations

1765[info] - should transform an infinite source

1766[info] - should transform an infinite source (stress test)

1767[info] RateLimiterTest:

1768[info] fixed rate RateLimiter

1769[info] - should drop operation when rate limit is exceeded

1770[info] - should restart rate limiter after given duration

1771[info] - should block operation when rate limit is exceeded

1772[info] - should respect time constraints when blocking

1773[info] - should respect time constraints when blocking concurrently

1774[info] - should allow to run more long running operations concurrently than max rate when not considering operation's time

1775[info] - should not allow to run more long running operations concurrently than max rate when considering operation time

1776[info] sliding window RateLimiter

1777[info] - should drop operation when rate limit is exceeded

1778[info] - should restart rate limiter after given duration

1779[info] - should block operation when rate limit is exceeded

1780[info] - should respect time constraints when blocking

1781[info] - should respect time constraints when blocking concurrently

1782[info] - should not allow to run more operations when operations are still running when considering operation time

1783[info] - should not allow to run more operations when operations are still running in window span when considering operation time

1784[info] bucket RateLimiter

1785[info] - should drop operation when rate limit is exceeded

1786[info] - should refill token after time elapsed from last refill and not before

1787[info] - should block operation when rate limit is exceeded

1788[info] - should respect time constraints when blocking

1789[info] - should respect time constraints when blocking concurrently

1790[info] FlowOpsSplitOnTest:

1791[info] splitOn

1792[info] - should split an empty flow

1793[info] - should split a flow with no delimiters

1794[info] - should split a flow with single-element delimiter at the beginning

1795[info] - should split a flow with single-element delimiter at the end

1796[info] - should split a flow with single-element delimiter in the middle

1797[info] - should split a flow with multiple single-element delimiters

1798[info] - should split a flow with adjacent single-element delimiters

1799[info] - should split a flow with only single-element delimiters

1800[info] - should split a flow with multi-element delimiter at the beginning

1801[info] - should split a flow with multi-element delimiter at the end

1802[info] - should split a flow with multi-element delimiter in the middle

1803[info] - should split a flow with multiple multi-element delimiters

1804[info] - should split a flow with adjacent multi-element delimiters

1805[info] - should split a flow with only multi-element delimiters

1806[info] - should split a flow with overlapping patterns

1807[info] - should split a flow with complex overlapping patterns

1808[info] - should handle empty delimiter by returning entire input as single chunk

1809[info] - should handle empty delimiter with empty input

1810[info] - should split a flow with string elements

1811[info] - should split a flow with multi-element string delimiter

1812[info] - should handle delimiter longer than input

1813[info] - should handle single element matching start of multi-element delimiter

1814[info] - should handle partial delimiter match at end

1815[info] - should split with delimiter that appears multiple times in sequence

1816[info] - should handle error propagation

1817[info] - should split a large flow efficiently

1818[info] - should handle repeated delimiter pattern correctly

1819[info] - should properly split when given a flow with delimiter patterns

1820[info] - should handle erroneous scenarios when delimiter processing fails

1821[info] FlowOpsMergeTest:

1822[info] merge

1823[info] - should merge two simple flows

1824[info] - should merge two async flows

1825[info] - should merge with a tick flow

1826[info] - should propagate error from the left

1827[info] - should propagate error from the right

1828[info] - should merge two flows, emitting all elements from the left when right completes

1829[info] - should merge two flows, emitting all elements from the right when left completes

1830[info] - should merge two flows, completing the resulting flow when the left flow completes

1831[info] - should merge two flows, completing the resulting flow when the right flow completes

1832[info] FlowOpsFlatMapTest:

1833[info] flatMap

1834[info] - should flatten simple flows

1835[info] - should propagate errors

1836[info] FlowCompanionIOOpsTest:

1837[info] fromInputStream

1838[info] - should handle an empty InputStream

1839[info] - should handle InputStream shorter than buffer size

1840[info] - should handle InputStream longer than buffer size

1841[info] - should close the InputStream after reading it

1843[info] fromFile

1844[info] - should read content from a file smaller than chunk size

1845[info] - should read content from a file larger than chunk size

1846[info] - should handle an empty file

1849[info] CollectParTest:

1850[info] collectPar

1851[info] - should output the same type as input

1852[info] - should run computations in parallel

1853[info] - should run not more computations than limit

1855[2026-01-08T00:31:19.247782143Z] [24] catch

1856[2026-01-08T00:31:19.548013423Z] [24] all done

1857[info] - should interrupt other computations in one fails

1858[info] FlowOpsFutureTest:

1859[info] future

1860[info] - should return the original future failure when future fails

1861[info] - should return future value

1862[info] FlowOpsInterleaveTest:

1863[info] interleave

1864[info] - should interleave with an empty source

1865[info] - should interleave two sources with default segment size

1866[info] - should interleave two sources with default segment size and different lengths

1867[info] - should interleave two sources with custom segment size

1868[info] - should interleave two sources with custom segment size and different lengths

1869[info] - should interleave two sources with different lengths and complete eagerly

1870[info] - should when empty, interleave with a non-empty source and complete eagerly

1871[info] - should interleave with an empty source and complete eagerly

1872[info] ParTest:

1873[info] par

1874[2026-01-08T00:31:19.671103846Z] [6025] b

1875[2026-01-08T00:31:19.771101645Z] [6024] a

1876[2026-01-08T00:31:19.771473070Z] [24] done

1877[info] - should run computations in parallel

1879[2026-01-08T00:31:19.873873199Z] [24] catch

1880[2026-01-08T00:31:20.174107435Z] [24] all done

1881[info] - should interrupt other computations in one fails

1882[info] parLimit

1883[info] - should run up to the given number of computations in parallel

1884[2026-01-08T00:31:20.880917945Z] [6040] x

1885[2026-01-08T00:31:20.880926096Z] [6041] x

1887[2026-01-08T00:31:20.891695244Z] [24] catch

1888[2026-01-08T00:31:21.191878755Z] [24] all done

1889[info] - should interrupt other computations in one fails

1890[info] parEither

1891[2026-01-08T00:31:21.293813458Z] [6047] b

1892[2026-01-08T00:31:21.393819625Z] [6046] a

1893[2026-01-08T00:31:21.394677270Z] [24] done

1894[info] - should run computations in parallel

1896[2026-01-08T00:31:21.796828301Z] [24] all done

1897[info] - should interrupt other computations in one fails

1898[info] SelectWithinTest:

1899[info] selectWithin

1900[info] - should select a clause that can complete immediately

1902[info] - should select a source that has a value immediately

1904[info] - should work with single clause

1905[info] - should work with three clauses

1906[info] - should work with four clauses

1907[info] - should work with five clauses

1908[info] - should work with sequence of clauses

1909[info] selectWithin with sources

1910[info] - should work with single source

1911[info] - should work with two sources

1912[info] - should work with three sources

1913[info] - should work with four sources

1914[info] - should work with five sources

1915[info] - should work with sequence of sources

1916[info] selectWithin timeout scenarios

1923[info] selectWithin error scenarios

1926[info] - should prioritize ready channels over closed ones

1927[info] selectWithin performance

1928[info] - should not timeout when clause can complete immediately

1929[info] - should respect timeout duration

1930[info] selectWithin with send clauses

1931[info] - should work with send clauses

1933[info] ImmediateRepeatTest:

1934[info] repeat

1935[info] - should repeat a function immediately

1936[info] - should repeat a function immediately with initial delay

1937[info] - should repeat a function immediately forever

1938[info] - should repeat a function immediately forever with initial delay

1939[info] FlowOpsDebounceByTest:

1940[info] debounceBy

1941[info] - should not debounce if applied on an empty flow

1942[info] - should not debounce if applied on a flow containing only distinct f(value)

1943[info] - should debounce if applied on a flow containing repeating f(value)

1944[info] - should debounce subsequent odd/prime numbers

1945[info] RaceTest:

1946[info] timeout

1947[2026-01-08T00:31:23.177857385Z] [24] timeout

1948[2026-01-08T00:31:23.178017262Z] [24] done

1949[info] - should short-circuit a long computation

1950[2026-01-08T00:31:25.679694176Z] [6112] no timeout

1951[2026-01-08T00:31:25.680104373Z] [24] done

1952[info] - should not interrupt a short computation

1953[info] timeoutOption

1954[2026-01-08T00:31:28.682199069Z] [24] done: None

1955[info] - should short-circuit a long computation

1956[info] race

1957[2026-01-08T00:31:31.184089854Z] [6117] fast

1958[info] - should race a slower and faster computation

1959[2026-01-08T00:31:32.686672987Z] [6118] fast

1960[info] - should race a faster and slower computation

1961[2026-01-08T00:31:33.888835863Z] [6120] error

1962[2026-01-08T00:31:34.188821311Z] [6121] slow

1963[info] - should return the first successful computation to complete

1967[info] raceEither

1968[2026-01-08T00:31:35.795813941Z] [6131] error

1969[2026-01-08T00:31:36.095823168Z] [6132] slow

1970[info] - should return the first successful computation to complete

1971[info] raceResult

1975[info] SourceOpsFutureSourceTest:

1976[info] SourceOps.futureSource

1977[info] - should return the original future failure when future fails

1979[info] - should return future's source values

1980[info] FilterParTest:

1981[info] filterPar

1982[info] - should output the same type as input

1983[info] - should run computations in parallel

1984[info] - should run not more computations than limit

1986[2026-01-08T00:31:37.849225717Z] [24] catch

1987[2026-01-08T00:31:38.149428014Z] [24] all done

1988[info] - should interrupt other computations in one fails

1989[info] SourceOpsForeachTest:

1990[info] Source.foreach

1991[info] - should iterate over a source

1992[info] - should iterate over a source using for-syntax

1993[info] - should convert source to a list

1994[info] FlowOpsEmptyTest:

1995[info] empty

1996[info] - should be empty

1997[info] SupervisedTest:

1998[info] supervised

1999[2026-01-08T00:31:38.259489413Z] [6343] b

2000[2026-01-08T00:31:38.359324726Z] [6342] a

2001[2026-01-08T00:31:38.359666155Z] [24] done

2002[info] - should wait until all forks complete

2003[2026-01-08T00:31:38.461235366Z] [6346] b

2004[2026-01-08T00:31:38.461619973Z] [24] done

2005[info] - should only wait until user forks complete

2006[2026-01-08T00:31:38.563418128Z] [6350] b

2007[2026-01-08T00:31:38.663984575Z] [24] done

2009[2026-01-08T00:31:38.866130271Z] [24] done

2011[2026-01-08T00:31:38.967867515Z] [6356] b

2012[2026-01-08T00:31:39.167616463Z] [6354] a

2013[2026-01-08T00:31:39.167852686Z] [24] done

2015[info] - should handle interruption of multiple forks with `joinEither` correctly

2016[info] SourceOpsFutureTest:

2017[info] Source.future

2018[info] - should return the original future failure when future fails

2020[info] - should return future value

2021[info] CircuitBreakerStateMachineTest:

2022[info] Circuit Breaker state machine

2023[info] - should keep closed with healthy metrics

2024[info] - should go to open after surpassing failure threshold

2025[info] - should go straight to half open after surpassing failure threshold with defined waitDurationOpenState = 0

2026[info] - should go back to open after timeout in half open passed

2027[info] - should update counter of completed operations in halfOpen state

2028[info] - should go back to closed after enough calls with good metrics are recorded

2029[info] - should go to open after enough calls with bad metrics are recorded in halfOpen state

2030[info] - should go to closed after enough calls with good metrics are recorded in halfOpen state

2031[info] - should go to half open after waitDurationOpenState passes

2032[info] OxAppTest:

2033[info] OxApp

2034[info] - should work in happy case

2035[info] OxApp

2036Clean shutdown timed out after 100 milliseconds, exiting.

2037[info] - should shutdown despite cleanup taking a long time

2038[info] OxApp

2039[info] - should work in interrupted case

2040[info] OxApp

2041[info] - should work in failed case

2042[info] OxApp

2044[info] OxApp.Simple

2045[info] - should work in happy case

2046[info] OxApp.Simple

2047[info] - should work in interrupted case

2048[info] OxApp.Simple

2049[info] - should work in failed case

2050[info] OxApp.WithErrors

2051[info] - should work in happy case

2052[info] OxApp.WithErrors

2053[info] - should work in interrupted case

2054[info] OxApp.WithErrors

2055[info] - should work in failed case

2056[info] FlowOpsMapStatefulConcatTest:

2057[info] mapStatefulConcat

2058[info] - should deduplicate

2059[info] - should count consecutive

2060[info] - should propagate errors in the mapping function

2061[info] - should propagate errors in the completion callback

2062[info] FlowOpsDropTest:

2063[info] drop

2064[info] - should not drop from the empty flow

2065[info] - should drop elements from the source

2066[info] - should return empty source when more elements than source length was dropped

2067[info] - should not drop when 'n == 0'

2068[info] FlowOpsRepeatEvalTest:

2069[info] repeatEval

2070[info] - should evaluate the element before each send

2071[info] - should evaluate the element before each send, as long as it's defined

2072[info] FlowPublisherPekkoTest:

2073[INFO] [01/08/2026 01:31:39.967] [] [CoordinatedShutdown(pekko://test)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]

2074[info] - a simple flow should emit elements to be processed by a pekko stream

2075[INFO] [01/08/2026 01:31:40.223] [] [CoordinatedShutdown(pekko://test)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]

2076[info] - a concurrent flow should emit elements to be processed by a pekko stream

2077[INFO] [01/08/2026 01:31:40.260] [] [CoordinatedShutdown(pekko://test)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]

2078[info] - create a flow from a simple publisher

2079[INFO] [01/08/2026 01:31:40.543] [] [CoordinatedShutdown(pekko://test)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]

2080[info] - create a flow from a concurrent publisher

2081[info] ImmediateRetryTest:

2082[info] Immediate retry

2083[info] - should retry a succeeding function

2084[info] - should fail fast when a function is not worth retrying

2085[info] - should retry a succeeding function with a custom success condition

2086[info] - should retry a failing function

2087[info] - should retry a failing function forever

2088[info] - should retry a succeeding Either

2089[info] - should fail fast when an Either is not worth retrying

2090[info] - should retry a succeeding Either with a custom success condition

2091[info] - should retry a failing Either

2092[info] Adaptive retry with immediate config

2093[info] - should retry a failing adaptive

2094[info] - should stop retrying after emptying bucket

2096[info] FlowOpsGroupByTest:

2097[info] groupBy

2098[info] - should handle empty flow

2099[info] - should handle single-element flow

2100[info] - should handle single-element flow (stress test)

2101[info] - should create simple groups without reaching parallelism limit

2102[info] - should complete groups when the parallelism limit is reached

2103[info] - should not exceed the parallelism limit, completing earliest-active child flows as done when necessary

2104[info] - should handle large flows

2105[info] - should handle non-integer grouping keys

2106[info] - should group when child processing is slow

2107[info] - should propagate errors from child flows

2108[info] - should propagate errors from child flows when the parent is blocked on sending

2111[info] FlowOpsLastOptionTest:

2112[info] lastOption

2113[info] - should return None for the empty flow

2114[info] - should return Some for a non-empty

2116[info] FlowOpsMapParUnorderedTest:

2117[info] mapParUnordered

2118[info] - should map over a source with parallelism limit 1

2119[info] - should map over a source with parallelism limit 2

2120[info] - should map over a source with parallelism limit 3

2121[info] - should map over a source with parallelism limit 4

2122[info] - should map over a source with parallelism limit 5

2123[info] - should map over a source with parallelism limit 6

2124[info] - should map over a source with parallelism limit 7

2125[info] - should map over a source with parallelism limit 8

2126[info] - should map over a source with parallelism limit 9

2127[info] - should map over a source with parallelism limit 10

2128[info] - should map over a source with parallelism limit 10 (stress test)

2129[info] + iteration 1

2130[info] + iteration 2

2131[info] + iteration 3

2132[info] + iteration 4

2133[info] + iteration 5

2134[info] + iteration 6

2135[info] + iteration 7

2136[info] + iteration 8

2137[info] + iteration 9

2138[info] + iteration 10

2139[info] + iteration 11

2140[info] + iteration 12

2141[info] + iteration 13

2142[info] + iteration 14

2143[info] + iteration 15

2144[info] + iteration 16

2145[info] + iteration 17

2146[info] + iteration 18

2147[info] + iteration 19

2148[info] + iteration 20

2149[info] + iteration 21

2150[info] + iteration 22

2151[info] + iteration 23

2152[info] + iteration 24

2153[info] + iteration 25

2154[info] + iteration 26

2155[info] + iteration 27

2156[info] + iteration 28

2157[info] + iteration 29

2158[info] + iteration 30

2159[info] + iteration 31

2160[info] + iteration 32

2161[info] + iteration 33

2162[info] + iteration 34

2163[info] + iteration 35

2164[info] + iteration 36

2165[info] + iteration 37

2166[info] + iteration 38

2167[info] + iteration 39

2168[info] + iteration 40

2169[info] + iteration 41

2170[info] + iteration 42

2171[info] + iteration 43

2172[info] + iteration 44

2173[info] + iteration 45

2174[info] + iteration 46

2175[info] + iteration 47

2176[info] + iteration 48

2177[info] + iteration 49

2178[info] + iteration 50

2179[info] + iteration 51

2180[info] + iteration 52

2181[info] + iteration 53

2182[info] + iteration 54

2183[info] + iteration 55

2184[info] + iteration 56

2185[info] + iteration 57

2186[info] + iteration 58

2187[info] + iteration 59

2188[info] + iteration 60

2189[info] + iteration 61

2190[info] + iteration 62

2191[info] + iteration 63

2192[info] + iteration 64

2193[info] + iteration 65

2194[info] + iteration 66

2195[info] + iteration 67

2196[info] + iteration 68

2197[info] + iteration 69

2198[info] + iteration 70

2199[info] + iteration 71

2200[info] + iteration 72

2201[info] + iteration 73

2202[info] + iteration 74

2203[info] + iteration 75

2204[info] + iteration 76

2205[info] + iteration 77

2206[info] + iteration 78

2207[info] + iteration 79

2208[info] + iteration 80

2209[info] + iteration 81

2210[info] + iteration 82

2211[info] + iteration 83

2212[info] + iteration 84

2213[info] + iteration 85

2214[info] + iteration 86

2215[info] + iteration 87

2216[info] + iteration 88

2217[info] + iteration 89

2218[info] + iteration 90

2219[info] + iteration 91

2220[info] + iteration 92

2221[info] + iteration 93

2222[info] + iteration 94

2223[info] + iteration 95

2224[info] + iteration 96

2225[info] + iteration 97

2226[info] + iteration 98

2227[info] + iteration 99

2228[info] + iteration 100

2229[info] - should propagate errors

2230[2026-01-08T00:31:56.387134611Z] [208018] done

2231[2026-01-08T00:31:56.387134578Z] [208017] done

2233[info] - should complete running forks and not start new ones when the mapping function fails

2234[2026-01-08T00:31:56.791400872Z] [208025] 2

2235[2026-01-08T00:31:56.791410426Z] [208024] 1

2236[info] - should complete running forks and not start new ones when the upstream fails

2237[2026-01-08T00:31:57.205160282Z] [208032] done

2238[2026-01-08T00:31:57.205153411Z] [208031] done

2240[info] - should cancel running forks when the surrounding scope closes due to an error

2241[info] - should emit downstream as soon as a value is ready, regardless of the incoming order

2242[info] ControlTest:

2243[info] timeout

2244[2026-01-08T00:31:58.813730581Z] [24] timeout

2245[2026-01-08T00:31:58.813872696Z] [24] done

2246[info] - should short-circuit a long computation

2248[2026-01-08T00:32:00.916207783Z] [208048] no timeout

2249[2026-01-08T00:32:00.916560805Z] [24] done

2250[info] - should not interrupt a short computation

2251[2026-01-08T00:32:03.318134221Z] [208050] done

2252[info] - should block a thread indefinitely

2253[info] timeoutOption

2255[info] timeoutEither

2257[info] FlowOpsConcatTest:

2258[info] - should concatenate flows

2259[info] - should concatenate flows using ++

2260[info] - should not evaluate subsequent flows if there's a failure

2261[info] FlowOpsFactoryMethodsTest:

2262[info] factory methods

2263[info] - should create a flow from a fork

2264[info] - should create an iterating flow

2265[info] - should unfold a function

2266[info] - should produce a range

2267[info] ChannelTest:

2268[info] channel with capacity 0

2269[info] - should send and receive two spaced elements

2270[info] - should send and receive many elements, with concurrent senders & receivers

2271[info] - should select from two receives, if the last one has elements

2272[info] - should select from three receives, if the last one has elements

2273[info] - should select a receive from multiple channels

2274[info] - should select a receive until all channels are done

2275[info] - should properly report channel state

2276[info] - should select from a non-done channel, if a value is immediately available

2277[info] - should select a done channel, when the channel is done immediately

2278[info] - should select a done channel, when the channel becomes done

2279[info] channel with capacity 1

2280[info] - should send and receive two spaced elements

2281[info] - should send and receive many elements, with concurrent senders & receivers

2282[info] - should select from two receives, if the last one has elements

2283[info] - should select from three receives, if the last one has elements

2284[info] - should select a receive from multiple channels

2285[info] - should select a receive until all channels are done

2286[info] - should properly report channel state

2287[info] - should select from a non-done channel, if a value is immediately available

2288[info] - should select a done channel, when the channel is done immediately

2289[info] - should select a done channel, when the channel becomes done

2290[info] channel with capacity 2

2291[info] - should send and receive two spaced elements

2292[info] - should send and receive many elements, with concurrent senders & receivers

2293[info] - should select from two receives, if the last one has elements

2294[info] - should select from three receives, if the last one has elements

2295[info] - should select a receive from multiple channels

2296[info] - should select a receive until all channels are done

2297[info] - should properly report channel state

2298[info] - should select from a non-done channel, if a value is immediately available

2299[info] - should select a done channel, when the channel is done immediately

2300[info] - should select a done channel, when the channel becomes done

2301[info] channel with capacity 100

2302[info] - should send and receive two spaced elements

2303[info] - should send and receive many elements, with concurrent senders & receivers

2304[info] - should select from two receives, if the last one has elements

2305[info] - should select from three receives, if the last one has elements

2306[info] - should select a receive from multiple channels

2307[info] - should select a receive until all channels are done

2308[info] - should properly report channel state

2309[info] - should select from a non-done channel, if a value is immediately available

2310[info] - should select a done channel, when the channel is done immediately

2311[info] - should select a done channel, when the channel becomes done

2312[info] channel with capacity 10000

2313[info] - should send and receive two spaced elements

2314[info] - should send and receive many elements, with concurrent senders & receivers

2315[info] - should select from two receives, if the last one has elements

2316[info] - should select from three receives, if the last one has elements

2317[info] - should select a receive from multiple channels

2318[info] - should select a receive until all channels are done

2319[info] - should properly report channel state

2320[info] - should select from a non-done channel, if a value is immediately available

2321[info] - should select a done channel, when the channel is done immediately

2322[info] - should select a done channel, when the channel becomes done

2323[info] buffered channel

2324[info] - should select a send when one is available

2325[info] channel

2326[info] - should receive from a channel until done

2327[info] - should not receive from a channel in case of an error

2328[info] rendezvous channel

2329[info] - should wait until elements are transmitted

2330[info] - should select a send when a receive is waiting

2331[info] - should select a send or receive depending on availability

2332[info] default

2333[info] - should use the default value if the clauses are not satisfiable

2334[info] - should not use the default value if a clause is satisfiable

2335[info] - should not use the default value if the channel is done

2336[info] - should use the default value once a source is done (buffered channel, stress test)

2337[info] + iteration 1

2338[info] + iteration 2

2339[info] + iteration 3

2340[info] + iteration 4

2341[info] + iteration 5

2342[info] + iteration 6

2343[info] + iteration 7

2344[info] + iteration 8

2345[info] + iteration 9

2346[info] + iteration 10

2347[info] + iteration 11

2348[info] + iteration 12

2349[info] + iteration 13

2350[info] + iteration 14

2351[info] + iteration 15

2352[info] + iteration 16

2353[info] + iteration 17

2354[info] + iteration 18

2355[info] + iteration 19

2356[info] + iteration 20

2357[info] + iteration 21

2358[info] + iteration 22

2359[info] + iteration 23

2360[info] + iteration 24

2361[info] + iteration 25

2362[info] + iteration 26

2363[info] + iteration 27

2364[info] + iteration 28

2365[info] + iteration 29

2366[info] + iteration 30

2367[info] + iteration 31

2368[info] + iteration 32

2369[info] + iteration 33

2370[info] + iteration 34

2371[info] + iteration 35

2372[info] + iteration 36

2373[info] + iteration 37

2374[info] + iteration 38

2375[info] + iteration 39

2376[info] + iteration 40

2377[info] + iteration 41

2378[info] + iteration 42

2379[info] + iteration 43

2380[info] + iteration 44

2381[info] + iteration 45

2382[info] + iteration 46

2383[info] + iteration 47

2384[info] + iteration 48

2385[info] + iteration 49

2386[info] + iteration 50

2387[info] + iteration 51

2388[info] + iteration 52

2389[info] + iteration 53

2390[info] + iteration 54

2391[info] + iteration 55

2392[info] + iteration 56

2393[info] + iteration 57

2394[info] + iteration 58

2395[info] + iteration 59

2396[info] + iteration 60

2397[info] + iteration 61

2398[info] + iteration 62

2399[info] + iteration 63

2400[info] + iteration 64

2401[info] + iteration 65

2402[info] + iteration 66

2403[info] + iteration 67

2404[info] + iteration 68

2405[info] + iteration 69

2406[info] + iteration 70

2407[info] + iteration 71

2408[info] + iteration 72

2409[info] + iteration 73

2410[info] + iteration 74

2411[info] + iteration 75

2412[info] + iteration 76

2413[info] + iteration 77

2414[info] + iteration 78

2415[info] + iteration 79

2416[info] + iteration 80

2417[info] + iteration 81

2418[info] + iteration 82

2419[info] + iteration 83

2420[info] + iteration 84

2421[info] + iteration 85

2422[info] + iteration 86

2423[info] + iteration 87

2424[info] + iteration 88

2425[info] + iteration 89

2426[info] + iteration 90

2427[info] + iteration 91

2428[info] + iteration 92

2429[info] + iteration 93

2430[info] + iteration 94

2431[info] + iteration 95

2432[info] + iteration 96

2433[info] + iteration 97

2434[info] + iteration 98

2435[info] + iteration 99

2436[info] + iteration 100

2437[info] FlowOpsOrElseTest:

2438[info] orElse

2439[info] - should emit elements only from the original source when it is not empty

2440[info] - should emit elements only from the alternative source when the original source is created empty

2441[info] - should emit elements only from the alternative source when the original source is empty

2442[info] - should return failed source when the original source is failed

2443[info] FlowOpsForeachTest:

2444[info] foreach

2445[info] - should iterate over a flow

2446[info] - should convert flow to a list

2447[info] SourceOpsEmptyTest:

2448[info] Source.empty

2449[info] - should be done

2450[info] - should be empty

2451[info] FlowOpsFlattenParTest:

2452[info] flattenPar

2453[info] - should pipe all elements of the child flows into the output flow

2454[info] - should handle empty flow

2455[info] - should handle singleton flow

2456[info] - should not flatten nested flows

2457[info] - should handle subsequent flatten calls

2458[info] - should run at most parallelism child flows

2459[info] - should pipe elements realtime

2460[info] - should propagate error of any of the child flows and stop piping

2461[info] - should propagate error of the parent flow and stop piping

2462[info] FlowOpsRetryTest:

2463[info] Flow.retry

2464[info] - should successfully run a flow without retries when no errors occur

2465[info] - should retry a failing flow with immediate schedule

2466[info] - should retry a failing flow with fixed interval schedule

2467[info] - should not retry a flow which fails downstream

2468[info] - should fail after exhausting all retry attempts

2469[info] - should use custom ResultPolicy to determine retry worthiness

2470[info] - should handle empty flows correctly

2471[info] - should handle flows that complete successfully on first attempt

2472[info] - should retry the entire flow when processing fails

2473[info] - should work with complex flows containing transformations

2475[info] LocalTest:

2476[info] fork locals

2477[2026-01-08T00:32:07.623006064Z] [24] main mid

2478[2026-01-08T00:32:07.723803266Z] [313242] In f1 = x

2479[2026-01-08T00:32:07.724117354Z] [24] result = a

2480[2026-01-08T00:32:07.824052968Z] [313245] In f3 = z

2481[2026-01-08T00:32:07.824395042Z] [24] result = a

2482[info] - should properly propagate values using supervisedWhere

2483[2026-01-08T00:32:07.825753340Z] [24] main mid

2484[2026-01-08T00:32:07.926193175Z] [313246] In f1 = x

2485[2026-01-08T00:32:07.926474650Z] [24] result = a

2486[2026-01-08T00:32:08.026873770Z] [313248] In f3 = z

2487[2026-01-08T00:32:08.027163999Z] [24] result = a

2488[info] - should properly propagate values using unsupervisedWhere

2489[2026-01-08T00:32:08.028737269Z] [313250] nested1 = x

2490[2026-01-08T00:32:08.029331778Z] [313251] nested2 = x

2491[2026-01-08T00:32:08.029511077Z] [24] outer = a

2492[info] - should propagate values across multiple scopes

2493[info] - should propagate errors from forks created within local values

2494[2026-01-08T00:32:08.031370347Z] [24] v1

2495[2026-01-08T00:32:08.031666228Z] [24] v2

2497[2026-01-08T00:32:08.031845972Z] [24] v1

2499[2026-01-08T00:32:08.032334141Z] [24] v1_1

2500[2026-01-08T00:32:08.032439817Z] [24] v2_1

2501[2026-01-08T00:32:08.032927505Z] [24] v1_2

2502[2026-01-08T00:32:08.032989150Z] [24] v2_2

2503[2026-01-08T00:32:08.033054241Z] [24] v1_1

2504[2026-01-08T00:32:08.033104214Z] [24] v2_1

2505[info] - should correctly set & unset multiple fork locals

2506[info] FlowOpsSampleTest:

2507[info] sample

2508[info] - should not sample anything from an empty flow

2509[info] - should not sample anything when 'n == 0'

2510[info] - should sample every element of the flow when 'n == 1'

2511[info] - should sample every nth element of the flow

2512[info] FlowOpsDrainTest:

2513[info] drain

2514[info] - should drain all elements

2515[info] - should run any side-effects that are part of the flow

2516[info] - should merge with another flow

2517[info] ActorTest:

2518[info] - should invoke methods on the actor

2519[info] - should protect the internal state of the actor

2523[info] FlowOpsSlidingTest:

2524[info] sliding

2525[info] - should create sliding windows for n = 2 and step = 1

2526[info] - should create sliding windows for n = 3 and step = 1

2527[info] - should create sliding windows for n = 2 and step = 2

2528[info] - should create sliding windows for n = 3 and step = 2

2529[info] - should create sliding windows for n = 1 and step = 2

2530[info] - should create sliding windows for n = 2 and step = 3

2531[info] - should create sliding windows for n = 2 and step = 3 (with 1 element remaining in the end)

2532[info] - should return failed source when the original source is failed

2533[info] FlowOpsTickTest:

2534[info] - should tick regularly

2535[info] - should tick immediately in case of a slow consumer, and then resume normal

2536Starting build for ProjectRef(file:/build/repo/,cron) (cron)... [3/6]

2537Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

2538[info] compiling 1 Scala source to /build/repo/cron/target/scala-3.8.0-RC6/classes ...

2539[info] done compiling

2540[info] compiling 1 Scala source to /build/repo/cron/target/scala-3.8.0-RC6/test-classes ...

2541[info] done compiling

2542[info] CronScheduleTest:

2543[info] repeat with cron schedule

2544[info] - should repeat a function every second (once)

2545[info] - should repeat a function every second (three times)

2546[info] - should provide initial delay

2547Starting build for ProjectRef(file:/build/repo/,otelContext) (otel-context)... [4/6]

2548Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

2549[info] compiling 1 Scala source to /build/repo/otel-context/target/scala-3.8.0-RC6/classes ...

2550[info] done compiling

2551Starting build for ProjectRef(file:/build/repo/,kafka) (kafka)... [5/6]

2552Compile scalacOptions: -encoding, utf8, -unchecked, -language:experimental.macros, -language:higherKinds, -language:implicitConversions, -Xkind-projector, -Wvalue-discard, -Wnonunit-statement, -Wunused:implicits, -Wunused:explicits, -Wunused:imports, -Wunused:locals, -Wunused:params, -Wunused:privates, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

2553[info] compiling 9 Scala sources to /build/repo/kafka/target/scala-3.8.0-RC6/classes ...

2559[info] done compiling

2560[info] compiling 6 Scala sources to /build/repo/kafka/target/scala-3.8.0-RC6/test-classes ...

2561[info] done compiling

256201:32:20.000 [pool-67-thread-9] INFO o.a.k.c.c.AbstractConfig - KafkaConfig values:

2563 add.partitions.to.txn.retry.backoff.max.ms = 100

2564 add.partitions.to.txn.retry.backoff.ms = 20

2565 advertised.listeners = BROKER://localhost:6001

2566 alter.config.policy.class.name = null

2567 alter.log.dirs.replication.quota.window.num = 11

2568 alter.log.dirs.replication.quota.window.size.seconds = 1

2569 authorizer.class.name =

2570 auto.create.topics.enable = true

2571 auto.leader.rebalance.enable = true

2572 background.threads = 10

2573 broker.heartbeat.interval.ms = 2000

2574 broker.id = 0

2575 broker.rack = null

2576 broker.session.timeout.ms = 9000

2577 client.quota.callback.class = null

2578 compression.gzip.level = -1

2579 compression.lz4.level = 9

2580 compression.type = producer

2581 compression.zstd.level = 3

2582 connection.failed.authentication.delay.ms = 100

2583 connections.max.idle.ms = 600000

2584 connections.max.reauth.ms = 0

2585 controlled.shutdown.enable = true

2586 controller.listener.names = CONTROLLER

2587 controller.performance.always.log.threshold.ms = 2000

2588 controller.performance.sample.period.ms = 60000

2589 controller.quorum.append.linger.ms = 25

2590 controller.quorum.bootstrap.servers = []

2591 controller.quorum.election.backoff.max.ms = 1000

2592 controller.quorum.election.timeout.ms = 1000

2593 controller.quorum.fetch.timeout.ms = 2000

2594 controller.quorum.request.timeout.ms = 2000

2595 controller.quorum.retry.backoff.ms = 20

2596 controller.quorum.voters = [0@localhost:6002]

2597 controller.quota.window.num = 11

2598 controller.quota.window.size.seconds = 1

2599 controller.socket.timeout.ms = 30000

2600 create.topic.policy.class.name = null

2601 default.replication.factor = 1

2602 delegation.token.expiry.check.interval.ms = 3600000

2603 delegation.token.expiry.time.ms = 86400000

2604 delegation.token.max.lifetime.ms = 604800000

2605 delegation.token.secret.key = null

2606 delete.records.purgatory.purge.interval.requests = 1

2607 delete.topic.enable = true

2608 early.start.listeners = null

2609 fetch.max.bytes = 57671680

2610 fetch.purgatory.purge.interval.requests = 1000

2611 group.consumer.assignors = [uniform, range]

2612 group.consumer.heartbeat.interval.ms = 5000

2613 group.consumer.max.heartbeat.interval.ms = 15000

2614 group.consumer.max.session.timeout.ms = 60000

2615 group.consumer.max.size = 2147483647

2616 group.consumer.migration.policy = bidirectional

2617 group.consumer.min.heartbeat.interval.ms = 5000

2618 group.consumer.min.session.timeout.ms = 45000

2619 group.consumer.regex.refresh.interval.ms = 600000

2620 group.consumer.session.timeout.ms = 45000

2621 group.coordinator.append.linger.ms = 5

2622 group.coordinator.rebalance.protocols = [classic, consumer, streams]

2623 group.coordinator.threads = 4

2624 group.initial.rebalance.delay.ms = 3000

2625 group.max.session.timeout.ms = 1800000

2626 group.max.size = 2147483647

2627 group.min.session.timeout.ms = 6000

2628 group.share.assignors = [simple]

2629 group.share.delivery.count.limit = 5

2630 group.share.enable = false

2631 group.share.heartbeat.interval.ms = 5000

2632 group.share.max.heartbeat.interval.ms = 15000

2633 group.share.max.record.lock.duration.ms = 60000

2634 group.share.max.session.timeout.ms = 60000

2635 group.share.max.share.sessions = 2000

2636 group.share.max.size = 200

2637 group.share.min.heartbeat.interval.ms = 5000

2638 group.share.min.record.lock.duration.ms = 15000

2639 group.share.min.session.timeout.ms = 45000

2640 group.share.partition.max.record.locks = 2000

2641 group.share.persister.class.name = org.apache.kafka.server.share.persister.DefaultStatePersister

2642 group.share.record.lock.duration.ms = 30000

2643 group.share.session.timeout.ms = 45000

2644 group.streams.heartbeat.interval.ms = 5000

2645 group.streams.max.heartbeat.interval.ms = 15000

2646 group.streams.max.session.timeout.ms = 60000

2647 group.streams.max.size = 2147483647

2648 group.streams.max.standby.replicas = 2

2649 group.streams.min.heartbeat.interval.ms = 5000

2650 group.streams.min.session.timeout.ms = 45000

2651 group.streams.num.standby.replicas = 0

2652 group.streams.session.timeout.ms = 45000

2653 initial.broker.registration.timeout.ms = 60000

2654 inter.broker.listener.name = BROKER

2655 internal.metadata.delete.delay.millis = 60000

2656 internal.metadata.log.segment.bytes = null

2657 internal.metadata.max.batch.size.in.bytes = 8388608

2658 internal.metadata.max.fetch.size.in.bytes = 8388608

2659 kafka.metrics.polling.interval.secs = 10

2660 kafka.metrics.reporters = []

2661 leader.imbalance.check.interval.seconds = 300

2662 listener.security.protocol.map = BROKER:PLAINTEXT,CONTROLLER:PLAINTEXT

2663 listeners = BROKER://localhost:6001,CONTROLLER://localhost:6002

2664 log.cleaner.backoff.ms = 15000

2665 log.cleaner.dedupe.buffer.size = 1048577

2666 log.cleaner.delete.retention.ms = 86400000

2667 log.cleaner.enable = true

2668 log.cleaner.io.buffer.load.factor = 0.9

2669 log.cleaner.io.buffer.size = 524288

2670 log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308

2671 log.cleaner.max.compaction.lag.ms = 9223372036854775807

2672 log.cleaner.min.cleanable.ratio = 0.5

2673 log.cleaner.min.compaction.lag.ms = 0

2674 log.cleaner.threads = 1

2675 log.cleanup.policy = [delete]

2676 log.dir = /tmp/kafka-logs

2677 log.dir.failure.timeout.ms = 30000

2678 log.dirs = /tmp/kafka-logs15769196062054598040

2679 log.flush.interval.messages = 1

2680 log.flush.interval.ms = null

2681 log.flush.offset.checkpoint.interval.ms = 60000

2682 log.flush.scheduler.interval.ms = 9223372036854775807

2683 log.flush.start.offset.checkpoint.interval.ms = 60000

2684 log.index.interval.bytes = 4096

2685 log.index.size.max.bytes = 10485760

2686 log.initial.task.delay.ms = 30000

2687 log.local.retention.bytes = -2

2688 log.local.retention.ms = -2

2689 log.message.timestamp.after.max.ms = 3600000

2690 log.message.timestamp.before.max.ms = 9223372036854775807

2691 log.message.timestamp.type = CreateTime

2692 log.preallocate = false

2693 log.retention.bytes = -1

2694 log.retention.check.interval.ms = 300000

2695 log.retention.hours = 168

2696 log.retention.minutes = null

2697 log.retention.ms = null

2698 log.roll.hours = 168

2699 log.roll.jitter.hours = 0

2700 log.roll.jitter.ms = null

2701 log.roll.ms = null

2702 log.segment.bytes = 1073741824

2703 log.segment.delete.delay.ms = 60000

2704 max.connection.creation.rate = 2147483647

2705 max.connections = 2147483647

2706 max.connections.per.ip = 2147483647

2707 max.connections.per.ip.overrides =

2708 max.incremental.fetch.session.cache.slots = 1000

2709 max.request.partition.size.limit = 2000

2710 message.max.bytes = 1048588

2711 metadata.log.dir = null

2712 metadata.log.max.record.bytes.between.snapshots = 20971520

2713 metadata.log.max.snapshot.interval.ms = 3600000

2714 metadata.log.segment.bytes = 1073741824

2715 metadata.log.segment.ms = 604800000

2716 metadata.max.idle.interval.ms = 500

2717 metadata.max.retention.bytes = 104857600

2718 metadata.max.retention.ms = 604800000

2719 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

2720 metrics.num.samples = 2

2721 metrics.recording.level = INFO

2722 metrics.sample.window.ms = 30000

2723 min.insync.replicas = 1

2724 node.id = 0

2725 num.io.threads = 8

2726 num.network.threads = 3

2727 num.partitions = 1

2728 num.recovery.threads.per.data.dir = 2

2729 num.replica.alter.log.dirs.threads = null

2730 num.replica.fetchers = 1

2731 offset.metadata.max.bytes = 4096

2732 offsets.commit.timeout.ms = 5000

2733 offsets.load.buffer.size = 5242880

2734 offsets.retention.check.interval.ms = 600000

2735 offsets.retention.minutes = 10080

2736 offsets.topic.compression.codec = 0

2737 offsets.topic.num.partitions = 1

2738 offsets.topic.replication.factor = 1

2739 offsets.topic.segment.bytes = 104857600

2740 principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder

2741 process.roles = [broker, controller]

2742 producer.id.expiration.check.interval.ms = 600000

2743 producer.id.expiration.ms = 86400000

2744 producer.purgatory.purge.interval.requests = 1000

2745 queued.max.request.bytes = -1

2746 queued.max.requests = 500

2747 quota.window.num = 11

2748 quota.window.size.seconds = 1

2749 remote.fetch.max.wait.ms = 500

2750 remote.list.offsets.request.timeout.ms = 30000

2751 remote.log.index.file.cache.total.size.bytes = 1073741824

2752 remote.log.manager.copier.thread.pool.size = 10

2753 remote.log.manager.copy.max.bytes.per.second = 9223372036854775807

2754 remote.log.manager.copy.quota.window.num = 11

2755 remote.log.manager.copy.quota.window.size.seconds = 1

2756 remote.log.manager.expiration.thread.pool.size = 10

2757 remote.log.manager.fetch.max.bytes.per.second = 9223372036854775807

2758 remote.log.manager.fetch.quota.window.num = 11

2759 remote.log.manager.fetch.quota.window.size.seconds = 1

2760 remote.log.manager.task.interval.ms = 30000

2761 remote.log.manager.task.retry.backoff.max.ms = 30000

2762 remote.log.manager.task.retry.backoff.ms = 500

2763 remote.log.manager.task.retry.jitter = 0.2

2764 remote.log.manager.thread.pool.size = 2

2765 remote.log.metadata.custom.metadata.max.bytes = 128

2766 remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager

2767 remote.log.metadata.manager.class.path = null

2768 remote.log.metadata.manager.impl.prefix = rlmm.config.

2769 remote.log.metadata.manager.listener.name = null

2770 remote.log.reader.max.pending.tasks = 100

2771 remote.log.reader.threads = 10

2772 remote.log.storage.manager.class.name = null

2773 remote.log.storage.manager.class.path = null

2774 remote.log.storage.manager.impl.prefix = rsm.config.

2775 remote.log.storage.system.enable = false

2776 replica.fetch.backoff.ms = 1000

2777 replica.fetch.max.bytes = 1048576

2778 replica.fetch.min.bytes = 1

2779 replica.fetch.response.max.bytes = 10485760

2780 replica.fetch.wait.max.ms = 500

2781 replica.high.watermark.checkpoint.interval.ms = 5000

2782 replica.lag.time.max.ms = 30000

2783 replica.selector.class = null

2784 replica.socket.receive.buffer.bytes = 65536

2785 replica.socket.timeout.ms = 30000

2786 replication.quota.window.num = 11

2787 replication.quota.window.size.seconds = 1

2788 request.timeout.ms = 30000

2789 sasl.client.callback.handler.class = null

2790 sasl.enabled.mechanisms = [GSSAPI]

2791 sasl.jaas.config = null

2792 sasl.kerberos.kinit.cmd = /usr/bin/kinit

2793 sasl.kerberos.min.time.before.relogin = 60000

2794 sasl.kerberos.principal.to.local.rules = [DEFAULT]

2795 sasl.kerberos.service.name = null

2796 sasl.kerberos.ticket.renew.jitter = 0.05

2797 sasl.kerberos.ticket.renew.window.factor = 0.8

2798 sasl.login.callback.handler.class = null

2799 sasl.login.class = null

2800 sasl.login.connect.timeout.ms = null

2801 sasl.login.read.timeout.ms = null

2802 sasl.login.refresh.buffer.seconds = 300

2803 sasl.login.refresh.min.period.seconds = 60

2804 sasl.login.refresh.window.factor = 0.8

2805 sasl.login.refresh.window.jitter = 0.05

2806 sasl.login.retry.backoff.max.ms = 10000

2807 sasl.login.retry.backoff.ms = 100

2808 sasl.mechanism.controller.protocol = GSSAPI

2809 sasl.mechanism.inter.broker.protocol = GSSAPI

2810 sasl.oauthbearer.assertion.algorithm = RS256

2811 sasl.oauthbearer.assertion.claim.aud = null

2812 sasl.oauthbearer.assertion.claim.exp.seconds = 300

2813 sasl.oauthbearer.assertion.claim.iss = null

2814 sasl.oauthbearer.assertion.claim.jti.include = false

2815 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

2816 sasl.oauthbearer.assertion.claim.sub = null

2817 sasl.oauthbearer.assertion.file = null

2818 sasl.oauthbearer.assertion.private.key.file = null

2819 sasl.oauthbearer.assertion.private.key.passphrase = null

2820 sasl.oauthbearer.assertion.template.file = null

2821 sasl.oauthbearer.client.credentials.client.id = null

2822 sasl.oauthbearer.client.credentials.client.secret = null

2823 sasl.oauthbearer.clock.skew.seconds = 30

2824 sasl.oauthbearer.expected.audience = null

2825 sasl.oauthbearer.expected.issuer = null

2826 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

2827 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

2828 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

2829 sasl.oauthbearer.jwks.endpoint.url = null

2830 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

2831 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

2832 sasl.oauthbearer.scope = null

2833 sasl.oauthbearer.scope.claim.name = scope

2834 sasl.oauthbearer.sub.claim.name = sub

2835 sasl.oauthbearer.token.endpoint.url = null

2836 sasl.server.callback.handler.class = null

2837 sasl.server.max.receive.size = 524288

2838 security.inter.broker.protocol = PLAINTEXT

2839 security.providers = null

2840 server.max.startup.time.ms = 9223372036854775807

2841 share.coordinator.append.linger.ms = 5

2842 share.coordinator.cold.partition.snapshot.interval.ms = 300000

2843 share.coordinator.load.buffer.size = 5242880

2844 share.coordinator.snapshot.update.records.per.snapshot = 500

2845 share.coordinator.state.topic.compression.codec = 0

2846 share.coordinator.state.topic.min.isr = 2

2847 share.coordinator.state.topic.num.partitions = 50

2848 share.coordinator.state.topic.prune.interval.ms = 300000

2849 share.coordinator.state.topic.replication.factor = 3

2850 share.coordinator.state.topic.segment.bytes = 104857600

2851 share.coordinator.threads = 1

2852 share.coordinator.write.timeout.ms = 5000

2853 share.fetch.purgatory.purge.interval.requests = 1000

2854 socket.connection.setup.timeout.max.ms = 30000

2855 socket.connection.setup.timeout.ms = 10000

2856 socket.listen.backlog.size = 50

2857 socket.receive.buffer.bytes = 102400

2858 socket.request.max.bytes = 104857600

2859 socket.send.buffer.bytes = 102400

2860 ssl.allow.dn.changes = false

2861 ssl.allow.san.changes = false

2862 ssl.cipher.suites = []

2863 ssl.client.auth = none

2864 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

2865 ssl.endpoint.identification.algorithm = https

2866 ssl.engine.factory.class = null

2867 ssl.key.password = null

2868 ssl.keymanager.algorithm = SunX509

2869 ssl.keystore.certificate.chain = null

2870 ssl.keystore.key = null

2871 ssl.keystore.location = null

2872 ssl.keystore.password = null

2873 ssl.keystore.type = JKS

2874 ssl.principal.mapping.rules = DEFAULT

2875 ssl.protocol = TLSv1.3

2876 ssl.provider = null

2877 ssl.secure.random.implementation = null

2878 ssl.trustmanager.algorithm = PKIX

2879 ssl.truststore.certificates = null

2880 ssl.truststore.location = null

2881 ssl.truststore.password = null

2882 ssl.truststore.type = JKS

2883 telemetry.max.bytes = 1048576

2884 transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000

2885 transaction.max.timeout.ms = 900000

2886 transaction.partition.verification.enable = true

2887 transaction.remove.expired.transaction.cleanup.interval.ms = 3600000

2888 transaction.state.log.load.buffer.size = 5242880

2889 transaction.state.log.min.isr = 1

2890 transaction.state.log.num.partitions = 50

2891 transaction.state.log.replication.factor = 1

2892 transaction.state.log.segment.bytes = 104857600

2893 transaction.two.phase.commit.enable = false

2894 transactional.id.expiration.ms = 604800000

2895 unclean.leader.election.enable = false

2896 unclean.leader.election.interval.ms = 300000

2897 unstable.api.versions.enable = false

2898 unstable.feature.versions.enable = false

290001:32:20.209 [pool-67-thread-9] INFO k.u.Log4jControllerRegistration$ - Registered `kafka:type=kafka.Log4jController` MBean

290101:32:20.265 [pool-67-thread-9] INFO i.g.e.EmbeddedKafka$ - [KafkaRaftServer nodeId=0] Rewriting /tmp/kafka-logs15769196062054598040/meta.properties

290201:32:20.324 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Starting controller

290301:32:20.642 [pool-67-thread-9] INFO k.n.ConnectionQuotas - Updated connection-accept-rate max connection creation rate to 2147483647

290401:32:20.670 [pool-67-thread-9] INFO k.n.SocketServer - [SocketServer listenerType=CONTROLLER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER)

290501:32:20.675 [pool-67-thread-9] INFO o.a.k.s.n.EndpointReadyFutures - authorizerStart completed for endpoint CONTROLLER. Endpoint is now READY.

290601:32:20.676 [pool-67-thread-9] INFO k.s.SharedServer - [SharedServer id=0] Starting SharedServer

290701:32:20.723 [pool-67-thread-9] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs15769196062054598040] Loading producer state till offset 0

290801:32:20.724 [pool-67-thread-9] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs15769196062054598040] Reloading from producer snapshot and rebuilding producer state from offset 0

290901:32:20.724 [pool-67-thread-9] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs15769196062054598040] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0

291001:32:20.742 [pool-67-thread-9] INFO k.r.KafkaMetadataLog$ - Initialized snapshots with IDs SortedSet() from /tmp/kafka-logs15769196062054598040/__cluster_metadata-0

291101:32:20.752 [raft-expiration-reaper] INFO o.a.k.r.TimingWheelExpirationService$ExpiredOperationReaper - [raft-expiration-reaper]: Starting

291201:32:20.764 [pool-67-thread-9] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Reading KRaft snapshot and log as part of the initialization

291301:32:20.766 [pool-67-thread-9] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Starting voters are VoterSet(voters={0=VoterNode(voterKey=ReplicaKey(id=0, directoryId=<undefined>), listeners=Endpoints(endpoints={ListenerName(CONTROLLER)=localhost/127.0.0.1:6002}), supportedKRaftVersion=SupportedVersionRange[min_version:0, max_version:0])})

291401:32:20.769 [pool-67-thread-9] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Starting request manager with static voters: [localhost:6002 (id: 0 rack: null isFenced: false)]

291501:32:20.773 [pool-67-thread-9] INFO o.a.k.r.QuorumState - [RaftManager id=0] Attempting durable transition to UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1397, highWatermark=Optional.empty) from null

291601:32:20.848 [pool-67-thread-9] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1397, highWatermark=Optional.empty) from null

291701:32:20.851 [pool-67-thread-9] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1508, highWatermark=Optional.empty) from UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1397, highWatermark=Optional.empty)

291801:32:20.852 [pool-67-thread-9] INFO o.a.k.r.QuorumState - [RaftManager id=0] Attempting durable transition to CandidateState(localId=0, localDirectoryId=lLBEpjnhyLJNV8aO2iBtcg, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1171) from ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1508, highWatermark=Optional.empty)

291901:32:20.858 [pool-67-thread-9] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to CandidateState(localId=0, localDirectoryId=lLBEpjnhyLJNV8aO2iBtcg, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1171) from ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1508, highWatermark=Optional.empty)

292001:32:20.863 [pool-67-thread-9] INFO o.a.k.r.QuorumState - [RaftManager id=0] Attempting durable transition to Leader(localVoterNode=VoterNode(voterKey=ReplicaKey(id=0, directoryId=lLBEpjnhyLJNV8aO2iBtcg), listeners=Endpoints(endpoints={ListenerName(CONTROLLER)=localhost/<unresolved>:6002}), supportedKRaftVersion=SupportedVersionRange[min_version:0, max_version:1]), epoch=1, epochStartOffset=0, highWatermark=Optional.empty, voterStates={0=ReplicaState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=0, localDirectoryId=lLBEpjnhyLJNV8aO2iBtcg, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1171)

292101:32:20.864 [pool-67-thread-9] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to Leader(localVoterNode=VoterNode(voterKey=ReplicaKey(id=0, directoryId=lLBEpjnhyLJNV8aO2iBtcg), listeners=Endpoints(endpoints={ListenerName(CONTROLLER)=localhost/<unresolved>:6002}), supportedKRaftVersion=SupportedVersionRange[min_version:0, max_version:1]), epoch=1, epochStartOffset=0, highWatermark=Optional.empty, voterStates={0=ReplicaState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=0, localDirectoryId=lLBEpjnhyLJNV8aO2iBtcg, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1171)

292201:32:20.881 [kafka-0-raft-outbound-request-thread] INFO o.a.k.r.KafkaNetworkChannel$SendThread - [kafka-0-raft-outbound-request-thread]: Starting

292301:32:20.881 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClientDriver - [kafka-0-raft-io-thread]: Starting

292401:32:20.895 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] initializeNewPublishers: The loader is still catching up because we have loaded up to offset -1, but the high water mark is 1

292501:32:20.896 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for controller quorum voters future

292601:32:20.896 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for controller quorum voters future

292701:32:20.900 [kafka-0-raft-io-thread] INFO o.a.k.r.LeaderState - [RaftManager id=0] High watermark set to LogOffsetMetadata(offset=1, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=91)]) for the first time for epoch 1 based on indexOfHw 0 and voters [ReplicaState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), endOffset=Optional[LogOffsetMetadata(offset=1, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=91)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)]

292801:32:20.905 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Registered the listener org.apache.kafka.image.loader.MetadataLoader@1873605344

292901:32:20.906 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Setting the next offset of org.apache.kafka.image.loader.MetadataLoader@1873605344 to 0 since there are no snapshots

293001:32:20.908 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] maybePublishMetadata(LOG_DELTA): The loader is still catching up because we have not loaded a controller record as of offset 0 and high water mark is 1

293101:32:20.928 [pool-67-thread-9] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task writeNoOpRecord to run every 500 ms

293201:32:20.928 [pool-67-thread-9] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task maybeFenceStaleBroker to run every 1125 ms

293301:32:20.929 [pool-67-thread-9] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task electPreferred to run every 300000 ms

293401:32:20.929 [pool-67-thread-9] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task electUnclean to run every 300000 ms

293501:32:20.929 [pool-67-thread-9] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task expireDelegationTokens to run every 3600000 ms

293601:32:20.929 [pool-67-thread-9] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task generatePeriodicPerformanceMessage to run every 60000 ms

293701:32:20.930 [pool-67-thread-9] INFO o.a.k.c.QuorumController - [QuorumController id=0] Creating new QuorumController with clusterId 4oa31apqQtabsfPXH-H0RA

293801:32:20.930 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@409757838

293901:32:20.930 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Setting the next offset of org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@409757838 to 0 since there are no snapshots

294001:32:20.932 [quorum-controller-0-event-handler] INFO o.a.k.c.QuorumController - [QuorumController id=0] Becoming the active controller at epoch 1, next write offset 1.

294101:32:20.936 [controller-0-ThrottledChannelReaper-Fetch] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Fetch]: Starting

294201:32:20.936 [controller-0-ThrottledChannelReaper-Produce] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Produce]: Starting

294301:32:20.937 [quorum-controller-0-event-handler] WARN o.a.k.c.QuorumController - [QuorumController id=0] Performing controller activation. The metadata log appears to be empty. Appending 1 bootstrap record(s) in metadata transaction at metadata.version 4.1-IV1 from bootstrap source 'the default bootstrap'.

294401:32:20.938 [controller-0-ThrottledChannelReaper-Request] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Request]: Starting

294501:32:20.939 [quorum-controller-0-event-handler] INFO o.a.k.c.OffsetControlManager - [QuorumController id=0] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1.

294601:32:20.940 [quorum-controller-0-event-handler] INFO o.a.k.c.FeatureControlManager - [QuorumController id=0] Replayed a FeatureLevelRecord setting metadata.version to 4.1-IV1

294701:32:20.940 [quorum-controller-0-event-handler] INFO o.a.k.c.OffsetControlManager - [QuorumController id=0] Replayed EndTransactionRecord() at offset 3.

294801:32:20.940 [controller-0-ThrottledChannelReaper-ControllerMutation] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-ControllerMutation]: Starting

294901:32:20.941 [quorum-controller-0-event-handler] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Activated periodic tasks: electPreferred, electUnclean, expireDelegationTokens, generatePeriodicPerformanceMessage, maybeFenceStaleBroker, writeNoOpRecord

295001:32:20.952 [ExpirationReaper-0-AlterAcls] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-AlterAcls]: Starting

295101:32:20.965 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for the controller metadata publishers to be installed

295201:32:20.965 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] initializeNewPublishers: The loader is still catching up because we have not loaded a controller record as of offset 0 and high water mark is 1

295301:32:20.965 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for the controller metadata publishers to be installed

295401:32:20.965 [pool-67-thread-9] INFO k.n.SocketServer - [SocketServer listenerType=CONTROLLER, nodeId=0] Enabling request processing.

295501:32:20.971 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] maybePublishMetadata(LOG_DELTA): The loader finished catching up to the current high water mark of 4

295601:32:20.973 [pool-67-thread-9] INFO k.n.DataPlaneAcceptor - Awaiting socket connections on localhost:6002.

295701:32:20.974 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing SnapshotGenerator with a snapshot at offset 3

295801:32:20.974 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing KRaftMetadataCachePublisher with a snapshot at offset 3

295901:32:20.974 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing FeaturesPublisher with a snapshot at offset 3

296001:32:20.981 [controller-0-to-controller-registration-channel-manager] INFO k.s.NodeToControllerRequestThread - [controller-0-to-controller-registration-channel-manager]: Starting

296101:32:20.981 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for all of the authorizer futures to be completed

296201:32:20.981 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for all of the authorizer futures to be completed

296301:32:20.981 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for all of the SocketServer Acceptors to be started

296401:32:20.982 [pool-67-thread-9] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for all of the SocketServer Acceptors to be started

296501:32:20.982 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=E5FeePitQvWsne22hoaE1A] initialized channel manager.

296601:32:20.982 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=E5FeePitQvWsne22hoaE1A] maybeSendControllerRegistration: cannot register yet because the metadata.version is not known yet.

296701:32:20.982 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Transition from SHUTDOWN to STARTING

296801:32:20.982 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Starting broker

296901:32:20.988 [controller-0-to-controller-registration-channel-manager] INFO k.s.NodeToControllerRequestThread - [controller-0-to-controller-registration-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:6002 (id: 0 rack: null isFenced: false)

297001:32:20.988 [kafka-0-metadata-loader-event-handler] INFO o.a.k.m.p.FeaturesPublisher - [ControllerServer id=0] Loaded new metadata FinalizedFeatures[metadataVersion=4.1-IV1, finalizedFeatures={metadata.version=27}, finalizedFeaturesEpoch=3].

297101:32:20.988 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing ControllerRegistrationsPublisher with a snapshot at offset 3

297201:32:20.988 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing ControllerRegistrationManager with a snapshot at offset 3

297301:32:20.988 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing DynamicConfigPublisher controller id=0 with a snapshot at offset 3

297401:32:20.989 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing DynamicClientQuotaPublisher controller id=0 with a snapshot at offset 3

297501:32:20.991 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing DynamicTopicClusterQuotaPublisher controller id=0 with a snapshot at offset 3

297601:32:20.992 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing ScramPublisher controller id=0 with a snapshot at offset 3

297701:32:20.992 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing DelegationTokenPublisher controller id=0 with a snapshot at offset 3

297801:32:20.994 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing ControllerMetadataMetricsPublisher with a snapshot at offset 3

297901:32:20.994 [broker-0-ThrottledChannelReaper-Fetch] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Fetch]: Starting

298001:32:20.994 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing AclPublisher controller id=0 with a snapshot at offset 3

298101:32:20.995 [broker-0-ThrottledChannelReaper-Produce] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Produce]: Starting

298201:32:20.997 [broker-0-ThrottledChannelReaper-Request] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Request]: Starting

298301:32:20.999 [broker-0-ThrottledChannelReaper-ControllerMutation] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-ControllerMutation]: Starting

298401:32:20.999 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=E5FeePitQvWsne22hoaE1A] sendControllerRegistration: attempting to send ControllerRegistrationRequestData(controllerId=0, incarnationId=E5FeePitQvWsne22hoaE1A, zkMigrationReady=false, listeners=[Listener(name='CONTROLLER', host='localhost', port=6002, securityProtocol=0)], features=[Feature(name='group.version', minSupportedVersion=0, maxSupportedVersion=1), Feature(name='transaction.version', minSupportedVersion=0, maxSupportedVersion=2), Feature(name='eligible.leader.replicas.version', minSupportedVersion=0, maxSupportedVersion=1), Feature(name='kraft.version', minSupportedVersion=0, maxSupportedVersion=1), Feature(name='metadata.version', minSupportedVersion=7, maxSupportedVersion=27), Feature(name='share.version', minSupportedVersion=0, maxSupportedVersion=1)])

298501:32:21.019 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for controller quorum voters future

298601:32:21.019 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for controller quorum voters future

298701:32:21.023 [broker-0-to-controller-forwarding-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-forwarding-channel-manager]: Starting

298801:32:21.023 [broker-0-to-controller-forwarding-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-forwarding-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:6002 (id: 0 rack: null isFenced: false)

298901:32:21.032 [client-metrics-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [client-metrics-reaper]: Starting

299001:32:21.092 [pool-67-thread-9] INFO k.n.ConnectionQuotas - Updated connection-accept-rate max connection creation rate to 2147483647

299101:32:21.098 [pool-67-thread-9] INFO k.n.SocketServer - [SocketServer listenerType=BROKER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(BROKER)

299201:32:21.102 [quorum-controller-0-event-handler] INFO o.a.k.c.ClusterControlManager - [QuorumController id=0] Replayed RegisterControllerRecord containing ControllerRegistration(id=0, incarnationId=E5FeePitQvWsne22hoaE1A, zkMigrationReady=false, listeners=[Endpoint(listenerName='CONTROLLER', securityProtocol=PLAINTEXT, host='localhost', port=6002)], supportedFeatures={eligible.leader.replicas.version: 0-1, group.version: 0-1, kraft.version: 0-1, metadata.version: 7-27, share.version: 0-1, transaction.version: 0-2}).

299301:32:21.104 [broker-0-to-controller-alter-partition-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-alter-partition-channel-manager]: Starting

299401:32:21.105 [broker-0-to-controller-alter-partition-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-alter-partition-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:6002 (id: 0 rack: null isFenced: false)

299501:32:21.111 [broker-0-to-controller-directory-assignments-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-directory-assignments-channel-manager]: Starting

299601:32:21.111 [broker-0-to-controller-directory-assignments-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-directory-assignments-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:6002 (id: 0 rack: null isFenced: false)

299701:32:21.116 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=E5FeePitQvWsne22hoaE1A] Our registration has been persisted to the metadata log.

299801:32:21.116 [controller-0-to-controller-registration-channel-manager] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=E5FeePitQvWsne22hoaE1A] RegistrationResponseHandler: controller acknowledged ControllerRegistrationRequest.

299901:32:21.127 [ExpirationReaper-0-Produce] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-Produce]: Starting

300001:32:21.128 [ExpirationReaper-0-Fetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-Fetch]: Starting

300101:32:21.129 [ExpirationReaper-0-DeleteRecords] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-DeleteRecords]: Starting

300201:32:21.129 [ExpirationReaper-0-RemoteFetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-RemoteFetch]: Starting

300301:32:21.130 [ExpirationReaper-0-RemoteListOffsets] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-RemoteListOffsets]: Starting

300401:32:21.131 [ExpirationReaper-0-ShareFetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-ShareFetch]: Starting

300501:32:21.145 [share-coordinator-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [share-coordinator-reaper]: Starting

300601:32:21.167 [share-coordinator-event-processor-0] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [share-coordinator-event-processor-0]: Starting

300701:32:21.173 [persister-state-manager-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [persister-state-manager-reaper]: Starting

300801:32:21.174 [PersisterStateManager] INFO o.a.k.s.s.p.PersisterStateManager$SendThread - [PersisterStateManager]: Starting

300901:32:21.175 [group-coordinator-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [group-coordinator-reaper]: Starting

301001:32:21.186 [group-coordinator-event-processor-0] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-0]: Starting

301101:32:21.186 [group-coordinator-event-processor-2] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-2]: Starting

301201:32:21.188 [group-coordinator-event-processor-1] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-1]: Starting

301301:32:21.189 [group-coordinator-event-processor-3] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-3]: Starting

301401:32:21.208 [pool-67-thread-9] INFO k.l.LogManager - Unable to read the broker epoch in /tmp/kafka-logs15769196062054598040.

301501:32:21.209 [broker-0-to-controller-heartbeat-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-heartbeat-channel-manager]: Starting

301601:32:21.211 [broker-0-to-controller-heartbeat-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-heartbeat-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:6002 (id: 0 rack: null isFenced: false)

301701:32:21.214 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] Incarnation Gcn3MmtLR3WalFXO7wSeuQ of broker 0 in cluster 4oa31apqQtabsfPXH-H0RA is now STARTING.

301801:32:21.218 [share-group-lock-timeout-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [share-group-lock-timeout-reaper]: Starting

301901:32:21.222 [quorum-controller-0-event-handler] INFO o.a.k.c.ClusterControlManager - [QuorumController id=0] No previous registration found for broker 0. New incarnation ID is Gcn3MmtLR3WalFXO7wSeuQ. Generated 0 record(s) to clean up previous incarnations. New broker epoch is 5.

302001:32:21.229 [quorum-controller-0-event-handler] INFO o.a.k.c.ClusterControlManager - [QuorumController id=0] Replayed initial RegisterBrokerRecord for broker 0: RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=Gcn3MmtLR3WalFXO7wSeuQ, brokerEpoch=5, endPoints=[BrokerEndpoint(name='BROKER', host='localhost', port=6001, securityProtocol=0)], features=[BrokerFeature(name='group.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='transaction.version', minSupportedVersion=0, maxSupportedVersion=2), BrokerFeature(name='eligible.leader.replicas.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='kraft.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='metadata.version', minSupportedVersion=7, maxSupportedVersion=27), BrokerFeature(name='share.version', minSupportedVersion=0, maxSupportedVersion=1)], rack=null, fenced=true, inControlledShutdown=false, logDirs=[lLBEpjnhyLJNV8aO2iBtcg])

302101:32:21.233 [ExpirationReaper-0-AlterAcls] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-AlterAcls]: Starting

302201:32:21.246 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the broker metadata publishers to be installed

302301:32:21.246 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the broker metadata publishers to be installed

302401:32:21.246 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the controller to acknowledge that we are caught up

302501:32:21.246 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing MetadataVersionPublisher(id=0) with a snapshot at offset 4

302601:32:21.247 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing BrokerMetadataPublisher with a snapshot at offset 4

302701:32:21.249 [kafka-0-metadata-loader-event-handler] INFO k.s.m.BrokerMetadataPublisher - [BrokerMetadataPublisher id=0] Publishing initial metadata at offset OffsetAndEpoch[offset=4, epoch=1] with metadata.version Optional[4.1-IV1].

302801:32:21.250 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Loading logs from log dirs ArrayBuffer(/tmp/kafka-logs15769196062054598040)

302901:32:21.253 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - No logs found to be loaded in /tmp/kafka-logs15769196062054598040

303001:32:21.253 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] Successfully registered broker 0 with broker epoch 5

303101:32:21.260 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Loaded 0 logs in 9ms

303201:32:21.260 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Starting log cleanup with a period of 300000 ms.

303301:32:21.261 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Starting log flusher with a default period of 9223372036854775807 ms.

303401:32:21.267 [kafka-0-metadata-loader-event-handler] INFO o.a.k.s.i.l.LogCleaner - Starting the log cleaner

303501:32:21.272 [kafka-log-cleaner-thread-0] INFO o.a.k.s.i.l.LogCleaner$CleanerThread - [kafka-log-cleaner-thread-0]: Starting

303601:32:21.276 [LogDirFailureHandler] INFO k.s.ReplicaManager$LogDirFailureHandler - [LogDirFailureHandler]: Starting

303701:32:21.277 [AddPartitionsToTxnSenderThread-0] INFO o.a.k.s.t.AddPartitionsToTxnManager - [AddPartitionsToTxnSenderThread-0]: Starting

303801:32:21.280 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.g.GroupCoordinatorService - [GroupCoordinator id=0] Starting up.

303901:32:21.281 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.g.GroupCoordinatorService - [GroupCoordinator id=0] Startup complete.

304001:32:21.282 [kafka-0-metadata-loader-event-handler] INFO k.c.t.TransactionCoordinator - [TransactionCoordinator id=0] Starting up.

304101:32:21.283 [kafka-0-metadata-loader-event-handler] INFO k.c.t.TransactionCoordinator - [TransactionCoordinator id=0] Startup complete.

304201:32:21.283 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.s.ShareCoordinatorService - [ShareCoordinator id=0] Starting up.

304301:32:21.283 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.s.ShareCoordinatorService - [ShareCoordinator id=0] Startup complete.

304401:32:21.284 [TxnMarkerSenderThread-0] INFO k.c.t.TransactionMarkerChannelManager - [TxnMarkerSenderThread-0]: Starting

304501:32:21.291 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing BrokerRegistrationTracker(id=0) with a snapshot at offset 4

304601:32:21.300 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] The broker has caught up. Transitioning from STARTING to RECOVERY.

304701:32:21.300 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the controller to acknowledge that we are caught up

304801:32:21.300 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the initial broker metadata update to be published

304901:32:21.300 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the initial broker metadata update to be published

305001:32:21.301 [pool-67-thread-9] INFO o.a.k.c.c.AbstractConfig - KafkaConfig values:

3051 add.partitions.to.txn.retry.backoff.max.ms = 100

3052 add.partitions.to.txn.retry.backoff.ms = 20

3053 advertised.listeners = BROKER://localhost:6001

3054 alter.config.policy.class.name = null

3055 alter.log.dirs.replication.quota.window.num = 11

3056 alter.log.dirs.replication.quota.window.size.seconds = 1

3057 authorizer.class.name =

3058 auto.create.topics.enable = true

3059 auto.leader.rebalance.enable = true

3060 background.threads = 10

3061 broker.heartbeat.interval.ms = 2000

3062 broker.id = 0

3063 broker.rack = null

3064 broker.session.timeout.ms = 9000

3065 client.quota.callback.class = null

3066 compression.gzip.level = -1

3067 compression.lz4.level = 9

3068 compression.type = producer

3069 compression.zstd.level = 3

3070 connection.failed.authentication.delay.ms = 100

3071 connections.max.idle.ms = 600000

3072 connections.max.reauth.ms = 0

3073 controlled.shutdown.enable = true

3074 controller.listener.names = CONTROLLER

3075 controller.performance.always.log.threshold.ms = 2000

3076 controller.performance.sample.period.ms = 60000

3077 controller.quorum.append.linger.ms = 25

3078 controller.quorum.bootstrap.servers = []

3079 controller.quorum.election.backoff.max.ms = 1000

3080 controller.quorum.election.timeout.ms = 1000

3081 controller.quorum.fetch.timeout.ms = 2000

3082 controller.quorum.request.timeout.ms = 2000

3083 controller.quorum.retry.backoff.ms = 20

3084 controller.quorum.voters = [0@localhost:6002]

3085 controller.quota.window.num = 11

3086 controller.quota.window.size.seconds = 1

3087 controller.socket.timeout.ms = 30000

3088 create.topic.policy.class.name = null

3089 default.replication.factor = 1

3090 delegation.token.expiry.check.interval.ms = 3600000

3091 delegation.token.expiry.time.ms = 86400000

3092 delegation.token.max.lifetime.ms = 604800000

3093 delegation.token.secret.key = null

3094 delete.records.purgatory.purge.interval.requests = 1

3095 delete.topic.enable = true

3096 early.start.listeners = null

3097 fetch.max.bytes = 57671680

3098 fetch.purgatory.purge.interval.requests = 1000

3099 group.consumer.assignors = [uniform, range]

3100 group.consumer.heartbeat.interval.ms = 5000

3101 group.consumer.max.heartbeat.interval.ms = 15000

3102 group.consumer.max.session.timeout.ms = 60000

3103 group.consumer.max.size = 2147483647

3104 group.consumer.migration.policy = bidirectional

3105 group.consumer.min.heartbeat.interval.ms = 5000

3106 group.consumer.min.session.timeout.ms = 45000

3107 group.consumer.regex.refresh.interval.ms = 600000

3108 group.consumer.session.timeout.ms = 45000

3109 group.coordinator.append.linger.ms = 5

3110 group.coordinator.rebalance.protocols = [classic, consumer, streams]

3111 group.coordinator.threads = 4

3112 group.initial.rebalance.delay.ms = 3000

3113 group.max.session.timeout.ms = 1800000

3114 group.max.size = 2147483647

3115 group.min.session.timeout.ms = 6000

3116 group.share.assignors = [simple]

3117 group.share.delivery.count.limit = 5

3118 group.share.enable = false

3119 group.share.heartbeat.interval.ms = 5000

3120 group.share.max.heartbeat.interval.ms = 15000

3121 group.share.max.record.lock.duration.ms = 60000

3122 group.share.max.session.timeout.ms = 60000

3123 group.share.max.share.sessions = 2000

3124 group.share.max.size = 200

3125 group.share.min.heartbeat.interval.ms = 5000

3126 group.share.min.record.lock.duration.ms = 15000

3127 group.share.min.session.timeout.ms = 45000

3128 group.share.partition.max.record.locks = 2000

3129 group.share.persister.class.name = org.apache.kafka.server.share.persister.DefaultStatePersister

3130 group.share.record.lock.duration.ms = 30000

3131 group.share.session.timeout.ms = 45000

3132 group.streams.heartbeat.interval.ms = 5000

3133 group.streams.max.heartbeat.interval.ms = 15000

3134 group.streams.max.session.timeout.ms = 60000

3135 group.streams.max.size = 2147483647

3136 group.streams.max.standby.replicas = 2

3137 group.streams.min.heartbeat.interval.ms = 5000

3138 group.streams.min.session.timeout.ms = 45000

3139 group.streams.num.standby.replicas = 0

3140 group.streams.session.timeout.ms = 45000

3141 initial.broker.registration.timeout.ms = 60000

3142 inter.broker.listener.name = BROKER

3143 internal.metadata.delete.delay.millis = 60000

3144 internal.metadata.log.segment.bytes = null

3145 internal.metadata.max.batch.size.in.bytes = 8388608

3146 internal.metadata.max.fetch.size.in.bytes = 8388608

3147 kafka.metrics.polling.interval.secs = 10

3148 kafka.metrics.reporters = []

3149 leader.imbalance.check.interval.seconds = 300

3150 listener.security.protocol.map = BROKER:PLAINTEXT,CONTROLLER:PLAINTEXT

3151 listeners = BROKER://localhost:6001,CONTROLLER://localhost:6002

3152 log.cleaner.backoff.ms = 15000

3153 log.cleaner.dedupe.buffer.size = 1048577

3154 log.cleaner.delete.retention.ms = 86400000

3155 log.cleaner.enable = true

3156 log.cleaner.io.buffer.load.factor = 0.9

3157 log.cleaner.io.buffer.size = 524288

3158 log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308

3159 log.cleaner.max.compaction.lag.ms = 9223372036854775807

3160 log.cleaner.min.cleanable.ratio = 0.5

3161 log.cleaner.min.compaction.lag.ms = 0

3162 log.cleaner.threads = 1

3163 log.cleanup.policy = [delete]

3164 log.dir = /tmp/kafka-logs

3165 log.dir.failure.timeout.ms = 30000

3166 log.dirs = /tmp/kafka-logs15769196062054598040

3167 log.flush.interval.messages = 1

3168 log.flush.interval.ms = null

3169 log.flush.offset.checkpoint.interval.ms = 60000

3170 log.flush.scheduler.interval.ms = 9223372036854775807

3171 log.flush.start.offset.checkpoint.interval.ms = 60000

3172 log.index.interval.bytes = 4096

3173 log.index.size.max.bytes = 10485760

3174 log.initial.task.delay.ms = 30000

3175 log.local.retention.bytes = -2

3176 log.local.retention.ms = -2

3177 log.message.timestamp.after.max.ms = 3600000

3178 log.message.timestamp.before.max.ms = 9223372036854775807

3179 log.message.timestamp.type = CreateTime

3180 log.preallocate = false

3181 log.retention.bytes = -1

3182 log.retention.check.interval.ms = 300000

3183 log.retention.hours = 168

3184 log.retention.minutes = null

3185 log.retention.ms = null

3186 log.roll.hours = 168

3187 log.roll.jitter.hours = 0

3188 log.roll.jitter.ms = null

3189 log.roll.ms = null

3190 log.segment.bytes = 1073741824

3191 log.segment.delete.delay.ms = 60000

3192 max.connection.creation.rate = 2147483647

3193 max.connections = 2147483647

3194 max.connections.per.ip = 2147483647

3195 max.connections.per.ip.overrides =

3196 max.incremental.fetch.session.cache.slots = 1000

3197 max.request.partition.size.limit = 2000

3198 message.max.bytes = 1048588

3199 metadata.log.dir = null

3200 metadata.log.max.record.bytes.between.snapshots = 20971520

3201 metadata.log.max.snapshot.interval.ms = 3600000

3202 metadata.log.segment.bytes = 1073741824

3203 metadata.log.segment.ms = 604800000

3204 metadata.max.idle.interval.ms = 500

3205 metadata.max.retention.bytes = 104857600

3206 metadata.max.retention.ms = 604800000

3207 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3208 metrics.num.samples = 2

3209 metrics.recording.level = INFO

3210 metrics.sample.window.ms = 30000

3211 min.insync.replicas = 1

3212 node.id = 0

3213 num.io.threads = 8

3214 num.network.threads = 3

3215 num.partitions = 1

3216 num.recovery.threads.per.data.dir = 2

3217 num.replica.alter.log.dirs.threads = null

3218 num.replica.fetchers = 1

3219 offset.metadata.max.bytes = 4096

3220 offsets.commit.timeout.ms = 5000

3221 offsets.load.buffer.size = 5242880

3222 offsets.retention.check.interval.ms = 600000

3223 offsets.retention.minutes = 10080

3224 offsets.topic.compression.codec = 0

3225 offsets.topic.num.partitions = 1

3226 offsets.topic.replication.factor = 1

3227 offsets.topic.segment.bytes = 104857600

3228 principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder

3229 process.roles = [broker, controller]

3230 producer.id.expiration.check.interval.ms = 600000

3231 producer.id.expiration.ms = 86400000

3232 producer.purgatory.purge.interval.requests = 1000

3233 queued.max.request.bytes = -1

3234 queued.max.requests = 500

3235 quota.window.num = 11

3236 quota.window.size.seconds = 1

3237 remote.fetch.max.wait.ms = 500

3238 remote.list.offsets.request.timeout.ms = 30000

3239 remote.log.index.file.cache.total.size.bytes = 1073741824

3240 remote.log.manager.copier.thread.pool.size = 10

3241 remote.log.manager.copy.max.bytes.per.second = 9223372036854775807

3242 remote.log.manager.copy.quota.window.num = 11

3243 remote.log.manager.copy.quota.window.size.seconds = 1

3244 remote.log.manager.expiration.thread.pool.size = 10

3245 remote.log.manager.fetch.max.bytes.per.second = 9223372036854775807

3246 remote.log.manager.fetch.quota.window.num = 11

3247 remote.log.manager.fetch.quota.window.size.seconds = 1

3248 remote.log.manager.task.interval.ms = 30000

3249 remote.log.manager.task.retry.backoff.max.ms = 30000

3250 remote.log.manager.task.retry.backoff.ms = 500

3251 remote.log.manager.task.retry.jitter = 0.2

3252 remote.log.manager.thread.pool.size = 2

3253 remote.log.metadata.custom.metadata.max.bytes = 128

3254 remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager

3255 remote.log.metadata.manager.class.path = null

3256 remote.log.metadata.manager.impl.prefix = rlmm.config.

3257 remote.log.metadata.manager.listener.name = null

3258 remote.log.reader.max.pending.tasks = 100

3259 remote.log.reader.threads = 10

3260 remote.log.storage.manager.class.name = null

3261 remote.log.storage.manager.class.path = null

3262 remote.log.storage.manager.impl.prefix = rsm.config.

3263 remote.log.storage.system.enable = false

3264 replica.fetch.backoff.ms = 1000

3265 replica.fetch.max.bytes = 1048576

3266 replica.fetch.min.bytes = 1

3267 replica.fetch.response.max.bytes = 10485760

3268 replica.fetch.wait.max.ms = 500

3269 replica.high.watermark.checkpoint.interval.ms = 5000

3270 replica.lag.time.max.ms = 30000

3271 replica.selector.class = null

3272 replica.socket.receive.buffer.bytes = 65536

3273 replica.socket.timeout.ms = 30000

3274 replication.quota.window.num = 11

3275 replication.quota.window.size.seconds = 1

3276 request.timeout.ms = 30000

3277 sasl.client.callback.handler.class = null

3278 sasl.enabled.mechanisms = [GSSAPI]

3279 sasl.jaas.config = null

3280 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3281 sasl.kerberos.min.time.before.relogin = 60000

3282 sasl.kerberos.principal.to.local.rules = [DEFAULT]

3283 sasl.kerberos.service.name = null

3284 sasl.kerberos.ticket.renew.jitter = 0.05

3285 sasl.kerberos.ticket.renew.window.factor = 0.8

3286 sasl.login.callback.handler.class = null

3287 sasl.login.class = null

3288 sasl.login.connect.timeout.ms = null

3289 sasl.login.read.timeout.ms = null

3290 sasl.login.refresh.buffer.seconds = 300

3291 sasl.login.refresh.min.period.seconds = 60

3292 sasl.login.refresh.window.factor = 0.8

3293 sasl.login.refresh.window.jitter = 0.05

3294 sasl.login.retry.backoff.max.ms = 10000

3295 sasl.login.retry.backoff.ms = 100

3296 sasl.mechanism.controller.protocol = GSSAPI

3297 sasl.mechanism.inter.broker.protocol = GSSAPI

3298 sasl.oauthbearer.assertion.algorithm = RS256

3299 sasl.oauthbearer.assertion.claim.aud = null

3300 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3301 sasl.oauthbearer.assertion.claim.iss = null

3302 sasl.oauthbearer.assertion.claim.jti.include = false

3303 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3304 sasl.oauthbearer.assertion.claim.sub = null

3305 sasl.oauthbearer.assertion.file = null

3306 sasl.oauthbearer.assertion.private.key.file = null

3307 sasl.oauthbearer.assertion.private.key.passphrase = null

3308 sasl.oauthbearer.assertion.template.file = null

3309 sasl.oauthbearer.client.credentials.client.id = null

3310 sasl.oauthbearer.client.credentials.client.secret = null

3311 sasl.oauthbearer.clock.skew.seconds = 30

3312 sasl.oauthbearer.expected.audience = null

3313 sasl.oauthbearer.expected.issuer = null

3314 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3315 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3316 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3317 sasl.oauthbearer.jwks.endpoint.url = null

3318 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3319 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3320 sasl.oauthbearer.scope = null

3321 sasl.oauthbearer.scope.claim.name = scope

3322 sasl.oauthbearer.sub.claim.name = sub

3323 sasl.oauthbearer.token.endpoint.url = null

3324 sasl.server.callback.handler.class = null

3325 sasl.server.max.receive.size = 524288

3326 security.inter.broker.protocol = PLAINTEXT

3327 security.providers = null

3328 server.max.startup.time.ms = 9223372036854775807

3329 share.coordinator.append.linger.ms = 5

3330 share.coordinator.cold.partition.snapshot.interval.ms = 300000

3331 share.coordinator.load.buffer.size = 5242880

3332 share.coordinator.snapshot.update.records.per.snapshot = 500

3333 share.coordinator.state.topic.compression.codec = 0

3334 share.coordinator.state.topic.min.isr = 2

3335 share.coordinator.state.topic.num.partitions = 50

3336 share.coordinator.state.topic.prune.interval.ms = 300000

3337 share.coordinator.state.topic.replication.factor = 3

3338 share.coordinator.state.topic.segment.bytes = 104857600

3339 share.coordinator.threads = 1

3340 share.coordinator.write.timeout.ms = 5000

3341 share.fetch.purgatory.purge.interval.requests = 1000

3342 socket.connection.setup.timeout.max.ms = 30000

3343 socket.connection.setup.timeout.ms = 10000

3344 socket.listen.backlog.size = 50

3345 socket.receive.buffer.bytes = 102400

3346 socket.request.max.bytes = 104857600

3347 socket.send.buffer.bytes = 102400

3348 ssl.allow.dn.changes = false

3349 ssl.allow.san.changes = false

3350 ssl.cipher.suites = []

3351 ssl.client.auth = none

3352 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3353 ssl.endpoint.identification.algorithm = https

3354 ssl.engine.factory.class = null

3355 ssl.key.password = null

3356 ssl.keymanager.algorithm = SunX509

3357 ssl.keystore.certificate.chain = null

3358 ssl.keystore.key = null

3359 ssl.keystore.location = null

3360 ssl.keystore.password = null

3361 ssl.keystore.type = JKS

3362 ssl.principal.mapping.rules = DEFAULT

3363 ssl.protocol = TLSv1.3

3364 ssl.provider = null

3365 ssl.secure.random.implementation = null

3366 ssl.trustmanager.algorithm = PKIX

3367 ssl.truststore.certificates = null

3368 ssl.truststore.location = null

3369 ssl.truststore.password = null

3370 ssl.truststore.type = JKS

3371 telemetry.max.bytes = 1048576

3372 transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000

3373 transaction.max.timeout.ms = 900000

3374 transaction.partition.verification.enable = true

3375 transaction.remove.expired.transaction.cleanup.interval.ms = 3600000

3376 transaction.state.log.load.buffer.size = 5242880

3377 transaction.state.log.min.isr = 1

3378 transaction.state.log.num.partitions = 50

3379 transaction.state.log.replication.factor = 1

3380 transaction.state.log.segment.bytes = 104857600

3381 transaction.two.phase.commit.enable = false

3382 transactional.id.expiration.ms = 604800000

3383 unclean.leader.election.enable = false

3384 unclean.leader.election.interval.ms = 300000

3385 unstable.api.versions.enable = false

3386 unstable.feature.versions.enable = false

338801:32:21.304 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the broker to be unfenced

338901:32:21.305 [quorum-controller-0-event-handler] INFO o.a.k.c.BrokerHeartbeatManager - [QuorumController id=0] The request from broker 0 to unfence has been granted because it has caught up with the offset of its register broker record 5.

339001:32:21.312 [quorum-controller-0-event-handler] INFO o.a.k.c.ClusterControlManager - [QuorumController id=0] Replayed BrokerRegistrationChangeRecord modifying the registration for broker 0: BrokerRegistrationChangeRecord(brokerId=0, brokerEpoch=5, fenced=-1, inControlledShutdown=0, logDirs=[])

339101:32:21.336 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] The broker has been unfenced. Transitioning from RECOVERY to RUNNING.

339201:32:21.336 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the broker to be unfenced

339301:32:21.336 [pool-67-thread-9] INFO o.a.k.s.n.EndpointReadyFutures - authorizerStart completed for endpoint BROKER. Endpoint is now READY.

339401:32:21.336 [pool-67-thread-9] INFO k.n.SocketServer - [SocketServer listenerType=BROKER, nodeId=0] Enabling request processing.

339501:32:21.337 [pool-67-thread-9] INFO k.n.DataPlaneAcceptor - Awaiting socket connections on localhost:6001.

339601:32:21.338 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for all of the authorizer futures to be completed

339701:32:21.338 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for all of the authorizer futures to be completed

339801:32:21.338 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for all of the SocketServer Acceptors to be started

339901:32:21.338 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for all of the SocketServer Acceptors to be started

340001:32:21.338 [pool-67-thread-9] INFO k.s.BrokerServer - [BrokerServer id=0] Transition from STARTING to STARTED

340101:32:21.362 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3402 acks = -1

3403 batch.size = 16384

3404 bootstrap.servers = [localhost:6001]

3405 buffer.memory = 33554432

3406 client.dns.lookup = use_all_dns_ips

3407 client.id = producer-1

3408 compression.gzip.level = -1

3409 compression.lz4.level = 9

3410 compression.type = none

3411 compression.zstd.level = 3

3412 connections.max.idle.ms = 540000

3413 delivery.timeout.ms = 120000

3414 enable.idempotence = true

3415 enable.metrics.push = true

3416 interceptor.classes = []

3417 key.serializer = class org.apache.kafka.common.serialization.StringSerializer

3418 linger.ms = 5

3419 max.block.ms = 10000

3420 max.in.flight.requests.per.connection = 5

3421 max.request.size = 1048576

3422 metadata.max.age.ms = 300000

3423 metadata.max.idle.ms = 300000

3424 metadata.recovery.rebootstrap.trigger.ms = 300000

3425 metadata.recovery.strategy = rebootstrap

3426 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3427 metrics.num.samples = 2

3428 metrics.recording.level = INFO

3429 metrics.sample.window.ms = 30000

3430 partitioner.adaptive.partitioning.enable = true

3431 partitioner.availability.timeout.ms = 0

3432 partitioner.class = null

3433 partitioner.ignore.keys = false

3434 receive.buffer.bytes = 32768

3435 reconnect.backoff.max.ms = 1000

3436 reconnect.backoff.ms = 50

3437 request.timeout.ms = 30000

3438 retries = 2147483647

3439 retry.backoff.max.ms = 1000

3440 retry.backoff.ms = 1000

3441 sasl.client.callback.handler.class = null

3442 sasl.jaas.config = null

3443 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3444 sasl.kerberos.min.time.before.relogin = 60000

3445 sasl.kerberos.service.name = null

3446 sasl.kerberos.ticket.renew.jitter = 0.05

3447 sasl.kerberos.ticket.renew.window.factor = 0.8

3448 sasl.login.callback.handler.class = null

3449 sasl.login.class = null

3450 sasl.login.connect.timeout.ms = null

3451 sasl.login.read.timeout.ms = null

3452 sasl.login.refresh.buffer.seconds = 300

3453 sasl.login.refresh.min.period.seconds = 60

3454 sasl.login.refresh.window.factor = 0.8

3455 sasl.login.refresh.window.jitter = 0.05

3456 sasl.login.retry.backoff.max.ms = 10000

3457 sasl.login.retry.backoff.ms = 100

3458 sasl.mechanism = GSSAPI

3459 sasl.oauthbearer.assertion.algorithm = RS256

3460 sasl.oauthbearer.assertion.claim.aud = null

3461 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3462 sasl.oauthbearer.assertion.claim.iss = null

3463 sasl.oauthbearer.assertion.claim.jti.include = false

3464 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3465 sasl.oauthbearer.assertion.claim.sub = null

3466 sasl.oauthbearer.assertion.file = null

3467 sasl.oauthbearer.assertion.private.key.file = null

3468 sasl.oauthbearer.assertion.private.key.passphrase = null

3469 sasl.oauthbearer.assertion.template.file = null

3470 sasl.oauthbearer.client.credentials.client.id = null

3471 sasl.oauthbearer.client.credentials.client.secret = null

3472 sasl.oauthbearer.clock.skew.seconds = 30

3473 sasl.oauthbearer.expected.audience = null

3474 sasl.oauthbearer.expected.issuer = null

3475 sasl.oauthbearer.header.urlencode = false

3476 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3477 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3478 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3479 sasl.oauthbearer.jwks.endpoint.url = null

3480 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3481 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3482 sasl.oauthbearer.scope = null

3483 sasl.oauthbearer.scope.claim.name = scope

3484 sasl.oauthbearer.sub.claim.name = sub

3485 sasl.oauthbearer.token.endpoint.url = null

3486 security.protocol = PLAINTEXT

3487 security.providers = null

3488 send.buffer.bytes = 131072

3489 socket.connection.setup.timeout.max.ms = 30000

3490 socket.connection.setup.timeout.ms = 10000

3491 ssl.cipher.suites = null

3492 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3493 ssl.endpoint.identification.algorithm = https

3494 ssl.engine.factory.class = null

3495 ssl.key.password = null

3496 ssl.keymanager.algorithm = SunX509

3497 ssl.keystore.certificate.chain = null

3498 ssl.keystore.key = null

3499 ssl.keystore.location = null

3500 ssl.keystore.password = null

3501 ssl.keystore.type = JKS

3502 ssl.protocol = TLSv1.3

3503 ssl.provider = null

3504 ssl.secure.random.implementation = null

3505 ssl.trustmanager.algorithm = PKIX

3506 ssl.truststore.certificates = null

3507 ssl.truststore.location = null

3508 ssl.truststore.password = null

3509 ssl.truststore.type = JKS

3510 transaction.timeout.ms = 60000

3511 transaction.two.phase.commit.enable = false

3512 transactional.id = null

3513 value.serializer = class org.apache.kafka.common.serialization.StringSerializer

351501:32:21.392 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

351601:32:21.403 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-1] Instantiated an idempotent producer.

351701:32:21.423 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

351801:32:21.423 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

351901:32:21.423 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1767832341423

352001:32:21.443 [data-plane-kafka-request-handler-1] INFO k.s.DefaultAutoTopicCreationManager - Sent auto-creation request for Set(t1) to the active controller.

352101:32:21.449 [kafka-producer-network-thread | producer-1] WARN o.a.k.c.NetworkClient - [Producer clientId=producer-1] The metadata response from the cluster reported a recoverable issue with correlation id 1 : {t1=UNKNOWN_TOPIC_OR_PARTITION}

352201:32:21.450 [kafka-producer-network-thread | producer-1] INFO o.a.k.c.Metadata - [Producer clientId=producer-1] Cluster ID: 4oa31apqQtabsfPXH-H0RA

352301:32:21.464 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] CreateTopics result(s): CreatableTopic(name='t1', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS

352401:32:21.464 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed TopicRecord for topic t1 with topic ID kA9eT6JuQ2KYgHsBQ_CgMQ.

352501:32:21.467 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed PartitionRecord for new partition t1-0 with topic ID kA9eT6JuQ2KYgHsBQ_CgMQ and PartitionRegistration(replicas=[0], directories=[lLBEpjnhyLJNV8aO2iBtcg], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).

352601:32:21.473 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Transitioning 1 partition(s) to local leaders.

352701:32:21.475 [kafka-0-metadata-loader-event-handler] INFO k.s.ReplicaFetcherManager - [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(t1-0)

352801:32:21.477 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Creating new partition t1-0 with topic id kA9eT6JuQ2KYgHsBQ_CgMQ.

352901:32:21.480 [quorum-controller-0-event-handler] INFO o.a.k.c.ProducerIdControlManager - [QuorumController id=0] Replaying ProducerIdsRecord ProducerIdsRecord(brokerId=0, brokerEpoch=5, nextProducerId=1000)

353001:32:21.491 [kafka-0-metadata-loader-event-handler] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=t1-0, dir=/tmp/kafka-logs15769196062054598040] Loading producer state till offset 0

353101:32:21.493 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Created log for partition t1-0 in /tmp/kafka-logs15769196062054598040/t1-0 with properties {}

353201:32:21.494 [kafka-0-metadata-loader-event-handler] INFO k.c.Partition - [Partition t1-0 broker=0] No checkpointed highwatermark is found for partition t1-0

353301:32:21.496 [kafka-0-metadata-loader-event-handler] INFO k.c.Partition - [Partition t1-0 broker=0] Log loaded for partition t1-0 with initial high watermark 0

353401:32:21.502 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Leader t1-0 with topic id Some(kA9eT6JuQ2KYgHsBQ_CgMQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.

353501:32:22.456 [kafka-producer-network-thread | producer-1] INFO o.a.k.c.p.i.TransactionManager - [Producer clientId=producer-1] ProducerId set to 0 with epoch 0

353601:32:22.490 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

353701:32:22.496 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

353801:32:22.496 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

353901:32:22.496 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

354001:32:22.496 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

354101:32:22.497 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-1 unregistered

354201:32:22.498 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3543 acks = -1

3544 batch.size = 16384

3545 bootstrap.servers = [localhost:6001]

3546 buffer.memory = 33554432

3547 client.dns.lookup = use_all_dns_ips

3548 client.id = producer-2

3549 compression.gzip.level = -1

3550 compression.lz4.level = 9

3551 compression.type = none

3552 compression.zstd.level = 3

3553 connections.max.idle.ms = 540000

3554 delivery.timeout.ms = 120000

3555 enable.idempotence = true

3556 enable.metrics.push = true

3557 interceptor.classes = []

3558 key.serializer = class org.apache.kafka.common.serialization.StringSerializer

3559 linger.ms = 5

3560 max.block.ms = 10000

3561 max.in.flight.requests.per.connection = 5

3562 max.request.size = 1048576

3563 metadata.max.age.ms = 300000

3564 metadata.max.idle.ms = 300000

3565 metadata.recovery.rebootstrap.trigger.ms = 300000

3566 metadata.recovery.strategy = rebootstrap

3567 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3568 metrics.num.samples = 2

3569 metrics.recording.level = INFO

3570 metrics.sample.window.ms = 30000

3571 partitioner.adaptive.partitioning.enable = true

3572 partitioner.availability.timeout.ms = 0

3573 partitioner.class = null

3574 partitioner.ignore.keys = false

3575 receive.buffer.bytes = 32768

3576 reconnect.backoff.max.ms = 1000

3577 reconnect.backoff.ms = 50

3578 request.timeout.ms = 30000

3579 retries = 2147483647

3580 retry.backoff.max.ms = 1000

3581 retry.backoff.ms = 1000

3582 sasl.client.callback.handler.class = null

3583 sasl.jaas.config = null

3584 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3585 sasl.kerberos.min.time.before.relogin = 60000

3586 sasl.kerberos.service.name = null

3587 sasl.kerberos.ticket.renew.jitter = 0.05

3588 sasl.kerberos.ticket.renew.window.factor = 0.8

3589 sasl.login.callback.handler.class = null

3590 sasl.login.class = null

3591 sasl.login.connect.timeout.ms = null

3592 sasl.login.read.timeout.ms = null

3593 sasl.login.refresh.buffer.seconds = 300

3594 sasl.login.refresh.min.period.seconds = 60

3595 sasl.login.refresh.window.factor = 0.8

3596 sasl.login.refresh.window.jitter = 0.05

3597 sasl.login.retry.backoff.max.ms = 10000

3598 sasl.login.retry.backoff.ms = 100

3599 sasl.mechanism = GSSAPI

3600 sasl.oauthbearer.assertion.algorithm = RS256

3601 sasl.oauthbearer.assertion.claim.aud = null

3602 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3603 sasl.oauthbearer.assertion.claim.iss = null

3604 sasl.oauthbearer.assertion.claim.jti.include = false

3605 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3606 sasl.oauthbearer.assertion.claim.sub = null

3607 sasl.oauthbearer.assertion.file = null

3608 sasl.oauthbearer.assertion.private.key.file = null

3609 sasl.oauthbearer.assertion.private.key.passphrase = null

3610 sasl.oauthbearer.assertion.template.file = null

3611 sasl.oauthbearer.client.credentials.client.id = null

3612 sasl.oauthbearer.client.credentials.client.secret = null

3613 sasl.oauthbearer.clock.skew.seconds = 30

3614 sasl.oauthbearer.expected.audience = null

3615 sasl.oauthbearer.expected.issuer = null

3616 sasl.oauthbearer.header.urlencode = false

3617 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3618 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3619 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3620 sasl.oauthbearer.jwks.endpoint.url = null

3621 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3622 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3623 sasl.oauthbearer.scope = null

3624 sasl.oauthbearer.scope.claim.name = scope

3625 sasl.oauthbearer.sub.claim.name = sub

3626 sasl.oauthbearer.token.endpoint.url = null

3627 security.protocol = PLAINTEXT

3628 security.providers = null

3629 send.buffer.bytes = 131072

3630 socket.connection.setup.timeout.max.ms = 30000

3631 socket.connection.setup.timeout.ms = 10000

3632 ssl.cipher.suites = null

3633 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3634 ssl.endpoint.identification.algorithm = https

3635 ssl.engine.factory.class = null

3636 ssl.key.password = null

3637 ssl.keymanager.algorithm = SunX509

3638 ssl.keystore.certificate.chain = null

3639 ssl.keystore.key = null

3640 ssl.keystore.location = null

3641 ssl.keystore.password = null

3642 ssl.keystore.type = JKS

3643 ssl.protocol = TLSv1.3

3644 ssl.provider = null

3645 ssl.secure.random.implementation = null

3646 ssl.trustmanager.algorithm = PKIX

3647 ssl.truststore.certificates = null

3648 ssl.truststore.location = null

3649 ssl.truststore.password = null

3650 ssl.truststore.type = JKS

3651 transaction.timeout.ms = 60000

3652 transaction.two.phase.commit.enable = false

3653 transactional.id = null

3654 value.serializer = class org.apache.kafka.common.serialization.StringSerializer

365601:32:22.498 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

365701:32:22.499 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-2] Instantiated an idempotent producer.

365801:32:22.503 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

365901:32:22.503 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

366001:32:22.503 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1767832342503

366101:32:22.511 [kafka-producer-network-thread | producer-2] INFO o.a.k.c.Metadata - [Producer clientId=producer-2] Cluster ID: 4oa31apqQtabsfPXH-H0RA

366201:32:22.512 [kafka-producer-network-thread | producer-2] INFO o.a.k.c.p.i.TransactionManager - [Producer clientId=producer-2] ProducerId set to 1 with epoch 0

366301:32:22.525 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

366401:32:22.529 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

366501:32:22.529 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

366601:32:22.529 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

366701:32:22.529 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

366801:32:22.530 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-2 unregistered

366901:32:22.530 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3670 acks = -1

3671 batch.size = 16384

3672 bootstrap.servers = [localhost:6001]

3673 buffer.memory = 33554432

3674 client.dns.lookup = use_all_dns_ips

3675 client.id = producer-3

3676 compression.gzip.level = -1

3677 compression.lz4.level = 9

3678 compression.type = none

3679 compression.zstd.level = 3

3680 connections.max.idle.ms = 540000

3681 delivery.timeout.ms = 120000

3682 enable.idempotence = true

3683 enable.metrics.push = true

3684 interceptor.classes = []

3685 key.serializer = class org.apache.kafka.common.serialization.StringSerializer

3686 linger.ms = 5

3687 max.block.ms = 10000

3688 max.in.flight.requests.per.connection = 5

3689 max.request.size = 1048576

3690 metadata.max.age.ms = 300000

3691 metadata.max.idle.ms = 300000

3692 metadata.recovery.rebootstrap.trigger.ms = 300000

3693 metadata.recovery.strategy = rebootstrap

3694 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3695 metrics.num.samples = 2

3696 metrics.recording.level = INFO

3697 metrics.sample.window.ms = 30000

3698 partitioner.adaptive.partitioning.enable = true

3699 partitioner.availability.timeout.ms = 0

3700 partitioner.class = null

3701 partitioner.ignore.keys = false

3702 receive.buffer.bytes = 32768

3703 reconnect.backoff.max.ms = 1000

3704 reconnect.backoff.ms = 50

3705 request.timeout.ms = 30000

3706 retries = 2147483647

3707 retry.backoff.max.ms = 1000

3708 retry.backoff.ms = 1000

3709 sasl.client.callback.handler.class = null

3710 sasl.jaas.config = null

3711 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3712 sasl.kerberos.min.time.before.relogin = 60000

3713 sasl.kerberos.service.name = null

3714 sasl.kerberos.ticket.renew.jitter = 0.05

3715 sasl.kerberos.ticket.renew.window.factor = 0.8

3716 sasl.login.callback.handler.class = null

3717 sasl.login.class = null

3718 sasl.login.connect.timeout.ms = null

3719 sasl.login.read.timeout.ms = null

3720 sasl.login.refresh.buffer.seconds = 300

3721 sasl.login.refresh.min.period.seconds = 60

3722 sasl.login.refresh.window.factor = 0.8

3723 sasl.login.refresh.window.jitter = 0.05

3724 sasl.login.retry.backoff.max.ms = 10000

3725 sasl.login.retry.backoff.ms = 100

3726 sasl.mechanism = GSSAPI

3727 sasl.oauthbearer.assertion.algorithm = RS256

3728 sasl.oauthbearer.assertion.claim.aud = null

3729 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3730 sasl.oauthbearer.assertion.claim.iss = null

3731 sasl.oauthbearer.assertion.claim.jti.include = false

3732 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3733 sasl.oauthbearer.assertion.claim.sub = null

3734 sasl.oauthbearer.assertion.file = null

3735 sasl.oauthbearer.assertion.private.key.file = null

3736 sasl.oauthbearer.assertion.private.key.passphrase = null

3737 sasl.oauthbearer.assertion.template.file = null

3738 sasl.oauthbearer.client.credentials.client.id = null

3739 sasl.oauthbearer.client.credentials.client.secret = null

3740 sasl.oauthbearer.clock.skew.seconds = 30

3741 sasl.oauthbearer.expected.audience = null

3742 sasl.oauthbearer.expected.issuer = null

3743 sasl.oauthbearer.header.urlencode = false

3744 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3745 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3746 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3747 sasl.oauthbearer.jwks.endpoint.url = null

3748 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3749 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3750 sasl.oauthbearer.scope = null

3751 sasl.oauthbearer.scope.claim.name = scope

3752 sasl.oauthbearer.sub.claim.name = sub

3753 sasl.oauthbearer.token.endpoint.url = null

3754 security.protocol = PLAINTEXT

3755 security.providers = null

3756 send.buffer.bytes = 131072

3757 socket.connection.setup.timeout.max.ms = 30000

3758 socket.connection.setup.timeout.ms = 10000

3759 ssl.cipher.suites = null

3760 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3761 ssl.endpoint.identification.algorithm = https

3762 ssl.engine.factory.class = null

3763 ssl.key.password = null

3764 ssl.keymanager.algorithm = SunX509

3765 ssl.keystore.certificate.chain = null

3766 ssl.keystore.key = null

3767 ssl.keystore.location = null

3768 ssl.keystore.password = null

3769 ssl.keystore.type = JKS

3770 ssl.protocol = TLSv1.3

3771 ssl.provider = null

3772 ssl.secure.random.implementation = null

3773 ssl.trustmanager.algorithm = PKIX

3774 ssl.truststore.certificates = null

3775 ssl.truststore.location = null

3776 ssl.truststore.password = null

3777 ssl.truststore.type = JKS

3778 transaction.timeout.ms = 60000

3779 transaction.two.phase.commit.enable = false

3780 transactional.id = null

3781 value.serializer = class org.apache.kafka.common.serialization.StringSerializer

378301:32:22.532 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

378401:32:22.533 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-3] Instantiated an idempotent producer.

378501:32:22.540 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

378601:32:22.540 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

378701:32:22.541 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1767832342540

378801:32:22.545 [kafka-producer-network-thread | producer-3] INFO o.a.k.c.Metadata - [Producer clientId=producer-3] Cluster ID: 4oa31apqQtabsfPXH-H0RA

378901:32:22.547 [kafka-producer-network-thread | producer-3] INFO o.a.k.c.p.i.TransactionManager - [Producer clientId=producer-3] ProducerId set to 2 with epoch 0

379001:32:22.559 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

379101:32:22.563 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

379201:32:22.563 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

379301:32:22.563 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

379401:32:22.563 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

379501:32:22.563 [pool-67-thread-9-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-3 unregistered

379601:32:22.586 [virtual-594] INFO o.a.k.c.c.AbstractConfig - ConsumerConfig values:

3797 allow.auto.create.topics = true

3798 auto.commit.interval.ms = 5000

3799 auto.offset.reset = earliest

3800 bootstrap.servers = [localhost:6001]

3801 check.crcs = true

3802 client.dns.lookup = use_all_dns_ips

3803 client.id = consumer-g1-1

3804 client.rack =

3805 connections.max.idle.ms = 540000

3806 default.api.timeout.ms = 60000

3807 enable.auto.commit = false

3808 enable.metrics.push = true

3809 exclude.internal.topics = true

3810 fetch.max.bytes = 52428800

3811 fetch.max.wait.ms = 500

3812 fetch.min.bytes = 1

3813 group.id = g1

3814 group.instance.id = null

3815 group.protocol = classic

3816 group.remote.assignor = null

3817 heartbeat.interval.ms = 3000

3818 interceptor.classes = []

3819 internal.leave.group.on.close = true

3820 internal.throw.on.fetch.stable.offset.unsupported = false

3821 isolation.level = read_uncommitted

3822 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

3823 max.partition.fetch.bytes = 1048576

3824 max.poll.interval.ms = 300000

3825 max.poll.records = 500

3826 metadata.max.age.ms = 300000

3827 metadata.recovery.rebootstrap.trigger.ms = 300000

3828 metadata.recovery.strategy = rebootstrap

3829 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3830 metrics.num.samples = 2

3831 metrics.recording.level = INFO

3832 metrics.sample.window.ms = 30000

3833 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]

3834 receive.buffer.bytes = 65536

3835 reconnect.backoff.max.ms = 1000

3836 reconnect.backoff.ms = 50

3837 request.timeout.ms = 30000

3838 retry.backoff.max.ms = 1000

3839 retry.backoff.ms = 100

3840 sasl.client.callback.handler.class = null

3841 sasl.jaas.config = null

3842 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3843 sasl.kerberos.min.time.before.relogin = 60000

3844 sasl.kerberos.service.name = null

3845 sasl.kerberos.ticket.renew.jitter = 0.05

3846 sasl.kerberos.ticket.renew.window.factor = 0.8

3847 sasl.login.callback.handler.class = null

3848 sasl.login.class = null

3849 sasl.login.connect.timeout.ms = null

3850 sasl.login.read.timeout.ms = null

3851 sasl.login.refresh.buffer.seconds = 300

3852 sasl.login.refresh.min.period.seconds = 60

3853 sasl.login.refresh.window.factor = 0.8

3854 sasl.login.refresh.window.jitter = 0.05

3855 sasl.login.retry.backoff.max.ms = 10000

3856 sasl.login.retry.backoff.ms = 100

3857 sasl.mechanism = GSSAPI

3858 sasl.oauthbearer.assertion.algorithm = RS256

3859 sasl.oauthbearer.assertion.claim.aud = null

3860 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3861 sasl.oauthbearer.assertion.claim.iss = null

3862 sasl.oauthbearer.assertion.claim.jti.include = false

3863 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3864 sasl.oauthbearer.assertion.claim.sub = null

3865 sasl.oauthbearer.assertion.file = null

3866 sasl.oauthbearer.assertion.private.key.file = null

3867 sasl.oauthbearer.assertion.private.key.passphrase = null

3868 sasl.oauthbearer.assertion.template.file = null

3869 sasl.oauthbearer.client.credentials.client.id = null

3870 sasl.oauthbearer.client.credentials.client.secret = null

3871 sasl.oauthbearer.clock.skew.seconds = 30

3872 sasl.oauthbearer.expected.audience = null

3873 sasl.oauthbearer.expected.issuer = null

3874 sasl.oauthbearer.header.urlencode = false

3875 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3876 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3877 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3878 sasl.oauthbearer.jwks.endpoint.url = null

3879 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3880 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3881 sasl.oauthbearer.scope = null

3882 sasl.oauthbearer.scope.claim.name = scope

3883 sasl.oauthbearer.sub.claim.name = sub

3884 sasl.oauthbearer.token.endpoint.url = null

3885 security.protocol = PLAINTEXT

3886 security.providers = null

3887 send.buffer.bytes = 131072

3888 session.timeout.ms = 45000

3889 share.acknowledgement.mode = implicit

3890 socket.connection.setup.timeout.max.ms = 30000

3891 socket.connection.setup.timeout.ms = 10000

3892 ssl.cipher.suites = null

3893 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3894 ssl.endpoint.identification.algorithm = https

3895 ssl.engine.factory.class = null

3896 ssl.key.password = null

3897 ssl.keymanager.algorithm = SunX509

3898 ssl.keystore.certificate.chain = null

3899 ssl.keystore.key = null

3900 ssl.keystore.location = null

3901 ssl.keystore.password = null

3902 ssl.keystore.type = JKS

3903 ssl.protocol = TLSv1.3

3904 ssl.provider = null

3905 ssl.secure.random.implementation = null

3906 ssl.trustmanager.algorithm = PKIX

3907 ssl.truststore.certificates = null

3908 ssl.truststore.location = null

3909 ssl.truststore.password = null

3910 ssl.truststore.type = JKS

3911 value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

391301:32:22.597 [virtual-594] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

391401:32:22.634 [virtual-594] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

391501:32:22.634 [virtual-594] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

391601:32:22.634 [virtual-594] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1767832342634

391701:32:22.655 [virtual-601] INFO o.a.k.c.c.i.ClassicKafkaConsumer - [Consumer clientId=consumer-g1-1, groupId=g1] Subscribed to topic(s): t1

391801:32:22.662 [virtual-601] INFO o.a.k.c.Metadata - [Consumer clientId=consumer-g1-1, groupId=g1] Cluster ID: 4oa31apqQtabsfPXH-H0RA

391901:32:22.663 [data-plane-kafka-request-handler-7] INFO k.s.DefaultAutoTopicCreationManager - Sent auto-creation request for Set(__consumer_offsets) to the active controller.

392001:32:22.667 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] CreateTopics result(s): CreatableTopic(name='__consumer_offsets', numPartitions=1, replicationFactor=1, assignments=[], configs=[CreatableTopicConfig(name='compression.type', value='producer'), CreatableTopicConfig(name='cleanup.policy', value='compact'), CreatableTopicConfig(name='segment.bytes', value='104857600')]): SUCCESS

392101:32:22.667 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed TopicRecord for topic __consumer_offsets with topic ID 2gGNgE87Sc-nMQZzezX5KA.

392201:32:22.668 [quorum-controller-0-event-handler] INFO o.a.k.c.ConfigurationControlManager - [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration compression.type to producer

392301:32:22.668 [quorum-controller-0-event-handler] INFO o.a.k.c.ConfigurationControlManager - [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration cleanup.policy to compact

392401:32:22.668 [quorum-controller-0-event-handler] INFO o.a.k.c.ConfigurationControlManager - [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration segment.bytes to 104857600

392501:32:22.668 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-0 with topic ID 2gGNgE87Sc-nMQZzezX5KA and PartitionRegistration(replicas=[0], directories=[lLBEpjnhyLJNV8aO2iBtcg], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).

392601:32:22.695 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Transitioning 1 partition(s) to local leaders.

392701:32:22.696 [kafka-0-metadata-loader-event-handler] INFO k.s.ReplicaFetcherManager - [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(__consumer_offsets-0)

392801:32:22.696 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Creating new partition __consumer_offsets-0 with topic id 2gGNgE87Sc-nMQZzezX5KA.

392901:32:22.698 [kafka-0-metadata-loader-event-handler] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__consumer_offsets-0, dir=/tmp/kafka-logs15769196062054598040] Loading producer state till offset 0

393001:32:22.699 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Created log for partition __consumer_offsets-0 in /tmp/kafka-logs15769196062054598040/__consumer_offsets-0 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}

393101:32:22.699 [kafka-0-metadata-loader-event-handler] INFO k.c.Partition - [Partition __consumer_offsets-0 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-0

393201:32:22.699 [kafka-0-metadata-loader-event-handler] INFO k.c.Partition - [Partition __consumer_offsets-0 broker=0] Log loaded for partition __consumer_offsets-0 with initial high watermark 0

393301:32:22.699 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Leader __consumer_offsets-0 with topic id Some(2gGNgE87Sc-nMQZzezX5KA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.

393401:32:22.701 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.c.r.CoordinatorRuntime - [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-0 with epoch 0

393501:32:22.708 [kafka-0-metadata-loader-event-handler] INFO k.s.m.DynamicConfigPublisher - [DynamicConfigPublisher broker id=0] Updating topic __consumer_offsets with new configuration : compression.type -> producer,cleanup.policy -> compact,segment.bytes -> 104857600

393601:32:22.722 [group-coordinator-event-processor-1] INFO o.a.k.c.c.r.CoordinatorRuntime - [GroupCoordinator id=0] Finished loading of metadata from __consumer_offsets-0 with epoch 0 in 1ms where 1ms was spent in the scheduler. Loaded 0 records which total to 0 bytes.

393701:32:22.765 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Discovered group coordinator localhost:6001 (id: 2147483647 rack: null isFenced: false)

393801:32:22.767 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] (Re-)joining group

393901:32:22.777 [group-coordinator-event-processor-3] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Dynamic member with unknown member id joins group g1 in Empty state. Created a new member id consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569 and requesting the member to rejoin with this id.

394001:32:22.779 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Request joining group due to: need to re-join with the given member-id: consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569

394101:32:22.780 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] (Re-)joining group

394201:32:22.784 [group-coordinator-event-processor-3] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Pending dynamic member with id consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569 joins group g1 in Empty state. Adding to the group now.

394301:32:22.785 [group-coordinator-event-processor-3] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Preparing to rebalance group g1 in state PreparingRebalance with old generation 0 (reason: Adding new member consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569 with group instance id null; client reason: need to re-join with the given member-id: consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569).

394401:32:25.788 [group-coordinator-event-processor-0] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Stabilized group g1 generation 1 with 1 members.

394501:32:25.790 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Successfully joined group with generation Generation{generationId=1, memberId='consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569', protocol='range'}

394601:32:25.795 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Finished assignment for group at generation 1: {consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569=Assignment(partitions=[t1-0])}

394701:32:25.799 [group-coordinator-event-processor-2] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Assignment received from leader consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569 for group g1 for generation 1. The group has 1 members, 0 of which are static.

394801:32:25.807 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Successfully synced group in generation Generation{generationId=1, memberId='consumer-g1-1-89c4f362-407c-4f14-bc75-2e60d2f30569', protocol='range'}

394901:32:25.807 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Notifying assignor about the new Assignment(partitions=[t1-0])

395001:32:25.809 [virtual-601] INFO o.a.k.c.c.i.ConsumerRebalanceListenerInvoker - [Consumer clientId=consumer-g1-1, groupId=g1] Adding newly assigned partitions: [t1-0]

395101:32:25.816 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Found no committed offset for partition t1-0

395201:32:25.828 [virtual-601] INFO o.a.k.c.c.i.SubscriptionState - [Consumer clientId=consumer-g1-1, groupId=g1] Resetting offset for partition t1-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:6001 (id: 0 rack: null isFenced: false)], epoch=0}}.

395301:32:26.112 [virtual-594] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3954 acks = -1

3955 batch.size = 16384

3956 bootstrap.servers = [localhost:6001]

3957 buffer.memory = 33554432

3958 client.dns.lookup = use_all_dns_ips

3959 client.id = producer-4

3960 compression.gzip.level = -1

3961 compression.lz4.level = 9

3962 compression.type = none

3963 compression.zstd.level = 3

3964 connections.max.idle.ms = 540000

3965 delivery.timeout.ms = 120000

3966 enable.idempotence = true

3967 enable.metrics.push = true

3968 interceptor.classes = []

3969 key.serializer = class org.apache.kafka.common.serialization.StringSerializer

3970 linger.ms = 5

3971 max.block.ms = 10000

3972 max.in.flight.requests.per.connection = 5

3973 max.request.size = 1048576

3974 metadata.max.age.ms = 300000

3975 metadata.max.idle.ms = 300000

3976 metadata.recovery.rebootstrap.trigger.ms = 300000

3977 metadata.recovery.strategy = rebootstrap

3978 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3979 metrics.num.samples = 2

3980 metrics.recording.level = INFO

3981 metrics.sample.window.ms = 30000

3982 partitioner.adaptive.partitioning.enable = true

3983 partitioner.availability.timeout.ms = 0

3984 partitioner.class = null

3985 partitioner.ignore.keys = false

3986 receive.buffer.bytes = 32768

3987 reconnect.backoff.max.ms = 1000

3988 reconnect.backoff.ms = 50

3989 request.timeout.ms = 30000

3990 retries = 2147483647

3991 retry.backoff.max.ms = 1000