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

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

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

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

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

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

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

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

86OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in kafka/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 mdcLogback/crossScalaVersions

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

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

92OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in flowReactiveStreams/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 13, 2026, 3:16:10 PM

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

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

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

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

219[info] [patched file /build/repo/core/src/main/scala/ox/local.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/flow/FlowOpsSplitTest.scala]

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

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

479[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsSampleTest.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/FilterParTest.scala]

482[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsDebounceTest.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/FlowOpsUsingSink.scala]

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

505[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsMapUsingSinkTest.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/FlowOpsMapTest.scala]

508[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsEmptyTest.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": 16732, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

574 "test-compile": {"status": "ok", "tookMs": 6469, "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": 508, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

584 "test-compile": {"status": "ok", "tookMs": 1076, "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": 54, "warnings": 16, "errors": 0, "sourceVersion": "3.7-migration"},

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

594 "test-compile": {"status": "ok", "tookMs": 21666, "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": 430, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

604 "test-compile": {"status": "ok", "tookMs": 634, "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": 272, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

614 "test-compile": {"status": "ok", "tookMs": 199, "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": 638, "warnings": 2, "errors": 0, "sourceVersion": "3.7-migration"},

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

624 "test-compile": {"status": "ok", "tookMs": 1727, "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 13, 2026, 3:17:13 PM

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 dec257e] 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

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

652Execute tests: true

653sbt project found:

654No prepare script found for project softwaremill/ox

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

656Scala version: 3.8.0

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

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"

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

709OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.8.0) in mdcLogback/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 on 8 projects.

713[info] Switching Scala version on:

714[info] flowReactiveStreams (3.8.0)

715[info] documentation (3.8.0)

716[info] cron (3.8.0)

717[info] * rootProject (3.8.0)

718[info] mdcLogback (3.8.0)

719[info] kafka (3.8.0)

720[info] core (3.8.0)

721[info] otelContext (3.8.0)

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 13, 2026, 3:17:25 PM

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

820[info] done compiling

821[info] compiling 1 Scala source to /build/repo/flow-reactive-streams/target/scala-3.8.0/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/classes ...

826[info] done compiling

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

828[info] done compiling

82915:17:48.144 [pool-28-thread-6] 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/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-13T14:18:35.049525372Z] [24] catch

1078[2026-01-13T14:18:35.349752516Z] [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-13T14:18:41.377349965Z] [24] in f

1089[info] - should do nothing

1091[2026-01-13T14:18:41.378381313Z] [24] in callback: boom!

1092[2026-01-13T14:18:41.378540230Z] [24] in catch: boom!

1094[2026-01-13T14:18:41.379219019Z] [24] 42

1095[2026-01-13T14:18:41.379292406Z] [24] after

1097[2026-01-13T14:18:41.381915419Z] [24] in catch: boom! 1

1099[info] pipe

1100[info] - should work

1101[info] tap

1102[2026-01-13T14:18:41.383706838Z] [24] Adding

1103[2026-01-13T14:18:41.383855526Z] [24] Got: 3

1104[info] - should work

1105[info] debug as extension

1106[info] - should work

1107[info] debug as top-level method

1108some label: 10

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[info] fork

1174[2026-01-13T14:18:41.588607321Z] [24] main mid

1175[2026-01-13T14:18:42.088804027Z] [435] f1 complete

1176[2026-01-13T14:18:42.589426154Z] [436] f2 complete

1177[2026-01-13T14:18:42.589840204Z] [24] result = 11

1178[info] - should run two forks concurrently

1179[2026-01-13T14:18:42.592986729Z] [438] f2 complete

1180[2026-01-13T14:18:42.593200108Z] [437] f1 complete

1181[2026-01-13T14:18:42.593408517Z] [24] result = 11

1182[info] - should allow nested forks

1183[2026-01-13T14:18:42.594499273Z] [24] main mid

1184[2026-01-13T14:18:43.095252486Z] [439] f1 complete

1185[2026-01-13T14:18:43.095563864Z] [24] result = 5

1186[2026-01-13T14:18:43.095805700Z] [440] f2 interrupted

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

1188[2026-01-13T14:18:43.098839454Z] [444] in fork

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

1190[2026-01-13T14:18:43.200853034Z] [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[2026-01-13T14:18:43.429437717Z] [24] allocate

1311[2026-01-13T14:18:43.430359886Z] [550] release 1

1312[info] ResourceTest:

1313[info] useInScope

1314[info] - should release resources after allocation

1315[2026-01-13T14:18:43.433823435Z] [24] allocate 1

1316[2026-01-13T14:18:43.434572004Z] [24] allocate 2

1317[2026-01-13T14:18:43.435775362Z] [551] release 2

1318[2026-01-13T14:18:43.435958595Z] [551] release 1

1319[info] - should release resources in reverse order

1320[2026-01-13T14:18:43.438753741Z] [24] allocate 1

1321[2026-01-13T14:18:43.439153639Z] [24] allocate 2

1322[2026-01-13T14:18:43.440413629Z] [552] release 2

1323[2026-01-13T14:18:43.440576544Z] [552] release 1

1326[2026-01-13T14:18:43.442551079Z] [24] allocate 1

1327[2026-01-13T14:18:43.443260919Z] [24] allocate 2

1328[2026-01-13T14:18:43.443523670Z] [553] release 2

1329[2026-01-13T14:18:43.444065593Z] [553] release 1

1332[2026-01-13T14:18:43.446109333Z] [24] allocate 1

1333[2026-01-13T14:18:43.446728471Z] [24] allocate 2

1334[2026-01-13T14:18:43.447374686Z] [554] release 2

1335[2026-01-13T14:18:43.447572254Z] [554] release 1

1338[2026-01-13T14:18:43.449619412Z] [24] in scope

1339[2026-01-13T14:18:43.450786066Z] [555] release

1340[2026-01-13T14:18:43.452950920Z] [24] allocate

1341[info] - should release registered resources

1342[2026-01-13T14:18:43.453041099Z] [24] in scope

1343[2026-01-13T14:18:43.453612679Z] [556] release

1344[info] - should use a resource

1345[2026-01-13T14:18:43.454426909Z] [24] allocate

1346[2026-01-13T14:18:43.454507850Z] [24] in scope

1347[2026-01-13T14:18:43.455108406Z] [557] release

1348[info] - should use a closeable resource

1349[2026-01-13T14:18:43.456092032Z] [24] allocate

1350[2026-01-13T14:18:43.456157244Z] [24] in scope

1351[2026-01-13T14:18:43.456782244Z] [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-13T14:18:52.076382503Z] [1916] done

1469[2026-01-13T14:18:52.076382544Z] [1915] 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-13T14:19:00.451281360Z] [2410] started

1623[2026-01-13T14:19:00.551624879Z] [2410] interrupted

1624[2026-01-13T14:19:01.052123343Z] [2410] interrupted done

1625[2026-01-13T14:19:01.052514327Z] [2408] cancel done

1626[info] - should block until the fork completes

1627[2026-01-13T14:19:02.055311693Z] [2411] cancel done

1628[2026-01-13T14:19:02.157250567Z] [2416] interrupted

1629[2026-01-13T14:19:02.257630553Z] [2416] interrupted done

1630[2026-01-13T14:19:02.257920329Z] [2414] cancel done

1631[2026-01-13T14:19:02.358566189Z] [2417] cancel done

1632[2026-01-13T14:19:02.460523867Z] [2422] interrupted

1633[2026-01-13T14:19:02.560908181Z] [2422] interrupted done

1634[2026-01-13T14:19:02.561144200Z] [2420] cancel done

1635[2026-01-13T14:19:02.661775173Z] [2423] cancel done

1636[2026-01-13T14:19:02.763736139Z] [2428] interrupted

1637[2026-01-13T14:19:02.864147364Z] [2428] interrupted done

1638[2026-01-13T14:19:02.864397985Z] [2426] cancel done

1639[2026-01-13T14:19:02.965056068Z] [2429] cancel done

1640[2026-01-13T14:19:03.067000997Z] [2434] interrupted

1641[2026-01-13T14:19:03.167389811Z] [2434] interrupted done

1642[2026-01-13T14:19:03.167635623Z] [2432] cancel done

1643[2026-01-13T14:19:03.268290801Z] [2435] cancel done

1644[2026-01-13T14:19:03.370177988Z] [2440] interrupted

1645[2026-01-13T14:19:03.470546894Z] [2440] interrupted done

1646[2026-01-13T14:19:03.470805452Z] [2438] cancel done

1647[2026-01-13T14:19:03.571442328Z] [2441] cancel done

1648[2026-01-13T14:19:03.673272796Z] [2446] interrupted

1649[2026-01-13T14:19:03.773628998Z] [2446] interrupted done

1650[2026-01-13T14:19:03.773883930Z] [2444] cancel done

1651[2026-01-13T14:19:03.874541002Z] [2447] cancel done

1652[2026-01-13T14:19:03.976436727Z] [2452] interrupted

1653[2026-01-13T14:19:04.076829754Z] [2452] interrupted done

1654[2026-01-13T14:19:04.077076993Z] [2450] cancel done

1655[2026-01-13T14:19:04.177691179Z] [2453] cancel done

1656[2026-01-13T14:19:04.279598643Z] [2458] interrupted

1657[2026-01-13T14:19:04.379965581Z] [2458] interrupted done

1658[2026-01-13T14:19:04.380187917Z] [2456] cancel done

1659[2026-01-13T14:19:04.480810632Z] [2459] cancel done

1660[2026-01-13T14:19:04.582755146Z] [2464] interrupted

1661[2026-01-13T14:19:04.683144395Z] [2464] interrupted done

1662[2026-01-13T14:19:04.683403961Z] [2462] cancel done

1663[2026-01-13T14:19:04.784035287Z] [2465] cancel done

1664[2026-01-13T14:19:04.885783541Z] [2470] interrupted

1665[2026-01-13T14:19:04.986162314Z] [2470] interrupted done

1666[2026-01-13T14:19:04.986447780Z] [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-13T14:19:05.189724133Z] [2471] cancel done

1690[2026-01-13T14:19:05.690069895Z] [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-13T14:19:07.827688194Z] [2505] 3

1734[2026-01-13T14:19:07.827605837Z] [2503] 1

1735[2026-01-13T14:19:07.827604351Z] [2502] 0

1736[2026-01-13T14:19:07.827631008Z] [2504] 2

1737[2026-01-13T14:19:07.827744837Z] [2506] 4

1738[2026-01-13T14:19:07.928162472Z] [2507] 5

1739[2026-01-13T14:19:07.928181921Z] [2508] 6

1740[2026-01-13T14:19:07.928231118Z] [2509] 7

1741[2026-01-13T14:19:07.928252164Z] [2510] 8

1742[2026-01-13T14:19:07.928286728Z] [2511] 9

1743[2026-01-13T14:19:08.028762814Z] [2514] 12

1744[2026-01-13T14:19:08.028955820Z] [2516] 14

1745[2026-01-13T14:19:08.028732753Z] [2513] 11

1746[2026-01-13T14:19:08.028727497Z] [2512] 10

1747[2026-01-13T14:19:08.028947989Z] [2515] 13

1748[2026-01-13T14:19:08.129424446Z] [2517] 15

1749[2026-01-13T14:19:08.129443798Z] [2518] 16

1750[2026-01-13T14:19:08.129468247Z] [2519] 17

1751[info] - should run computations in parallel

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

1754[2026-01-13T14:19:08.467757659Z] [24] catch

1755[2026-01-13T14:19:08.767940826Z] [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-13T14:19:53.136699391Z] [24] catch

1856[2026-01-13T14:19:53.436894679Z] [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-13T14:19:53.557880299Z] [6025] b

1875[2026-01-13T14:19:53.657885960Z] [6024] a

1876[2026-01-13T14:19:53.658217034Z] [24] done

1877[info] - should run computations in parallel

1879[2026-01-13T14:19:53.760917725Z] [24] catch

1880[2026-01-13T14:19:54.061142307Z] [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-13T14:19:54.767505029Z] [6040] x

1885[2026-01-13T14:19:54.767505002Z] [6041] x

1887[2026-01-13T14:19:54.778305498Z] [24] catch

1888[2026-01-13T14:19:55.078501667Z] [24] all done

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

1890[info] parEither

1891[2026-01-13T14:19:55.180383248Z] [6047] b

1892[2026-01-13T14:19:55.280384863Z] [6046] a

1893[2026-01-13T14:19:55.281215804Z] [24] done

1894[info] - should run computations in parallel

1896[2026-01-13T14:19:55.683314923Z] [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-13T14:19:57.062698441Z] [24] timeout

1948[2026-01-13T14:19:57.062838993Z] [24] done

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

1950[2026-01-13T14:19:59.564257915Z] [6112] no timeout

1951[2026-01-13T14:19:59.564623520Z] [24] done

1952[info] - should not interrupt a short computation

1953[info] timeoutOption

1954[2026-01-13T14:20:02.566634503Z] [24] done: None

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

1956[info] race

1957[2026-01-13T14:20:05.068608409Z] [6117] fast

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

1959[2026-01-13T14:20:06.571167552Z] [6118] fast

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

1961[2026-01-13T14:20:07.773253163Z] [6120] error

1962[2026-01-13T14:20:08.073237389Z] [6121] slow

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

1967[info] raceEither

1968[2026-01-13T14:20:09.680328990Z] [6131] error

1969[2026-01-13T14:20:09.980360955Z] [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-13T14:20:11.729797342Z] [24] catch

1987[2026-01-13T14:20:12.029988406Z] [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-13T14:20:12.138887413Z] [6343] b

2000[2026-01-13T14:20:12.238797735Z] [6342] a

2001[2026-01-13T14:20:12.239091525Z] [24] done

2002[info] - should wait until all forks complete

2003[2026-01-13T14:20:12.340766193Z] [6346] b

2004[2026-01-13T14:20:12.341201393Z] [24] done

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

2006[2026-01-13T14:20:12.443230369Z] [6350] b

2007[2026-01-13T14:20:12.543760586Z] [24] done

2009[2026-01-13T14:20:12.745888889Z] [24] done

2011[2026-01-13T14:20:12.847606546Z] [6356] b

2012[2026-01-13T14:20:13.047379113Z] [6354] a

2013[2026-01-13T14:20:13.047648912Z] [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/13/2026 15:20:13.857] [] [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/13/2026 15:20:14.104] [] [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/13/2026 15:20:14.145] [] [CoordinatedShutdown(pekko://test)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]

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

2079[INFO] [01/13/2026 15:20:14.435] [] [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-13T14:20:30.267704494Z] [208017] done

2231[2026-01-13T14:20:30.267704487Z] [208018] done

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

2234[2026-01-13T14:20:30.671489816Z] [208025] 2

2235[2026-01-13T14:20:30.671489831Z] [208024] 1

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

2237[2026-01-13T14:20:31.085565725Z] [208031] done

2238[2026-01-13T14:20:31.085573867Z] [208032] 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-13T14:20:32.693762436Z] [24] timeout

2245[2026-01-13T14:20:32.693907777Z] [24] done

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

2248[2026-01-13T14:20:34.796529356Z] [208048] no timeout

2249[2026-01-13T14:20:34.796899154Z] [24] done

2250[info] - should not interrupt a short computation

2251[2026-01-13T14:20:37.198474748Z] [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-13T14:20:41.502698223Z] [24] main mid

2478[2026-01-13T14:20:41.603262204Z] [313242] In f1 = x

2479[2026-01-13T14:20:41.603772486Z] [24] result = a

2480[2026-01-13T14:20:41.703601374Z] [313245] In f3 = z

2481[2026-01-13T14:20:41.703910327Z] [24] result = a

2482[info] - should properly propagate values using supervisedWhere

2483[2026-01-13T14:20:41.705869369Z] [24] main mid

2484[2026-01-13T14:20:41.806499424Z] [313246] In f1 = x

2485[2026-01-13T14:20:41.806761559Z] [24] result = a

2486[2026-01-13T14:20:41.907321416Z] [313248] In f3 = z

2487[2026-01-13T14:20:41.907614764Z] [24] result = a

2488[info] - should properly propagate values using unsupervisedWhere

2489[2026-01-13T14:20:41.909173598Z] [313250] nested1 = x

2490[2026-01-13T14:20:41.909603230Z] [313251] nested2 = x

2491[2026-01-13T14:20:41.909743422Z] [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-13T14:20:41.911429491Z] [24] v1

2495[2026-01-13T14:20:41.911758118Z] [24] v2

2497[2026-01-13T14:20:41.911901445Z] [24] v1

2499[2026-01-13T14:20:41.912385781Z] [24] v1_1

2500[2026-01-13T14:20:41.912780318Z] [24] v2_1

2501[2026-01-13T14:20:41.913240037Z] [24] v1_2

2502[2026-01-13T14:20:41.913327521Z] [24] v2_2

2503[2026-01-13T14:20:41.913373056Z] [24] v1_1

2504[2026-01-13T14:20:41.913413101Z] [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/classes ...

2539[info] done compiling

2540[info] compiling 1 Scala source to /build/repo/cron/target/scala-3.8.0/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/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/classes ...

2559[info] done compiling

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

2561[info] done compiling

256215:20:53.877 [pool-67-thread-3] 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-logs5982689497894266552

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

290015:20:54.083 [pool-67-thread-3] INFO k.u.Log4jControllerRegistration$ - Registered `kafka:type=kafka.Log4jController` MBean

290115:20:54.131 [pool-67-thread-3] INFO i.g.e.EmbeddedKafka$ - [KafkaRaftServer nodeId=0] Rewriting /tmp/kafka-logs5982689497894266552/meta.properties

290215:20:54.184 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Starting controller

290315:20:54.587 [pool-67-thread-3] INFO k.n.ConnectionQuotas - Updated connection-accept-rate max connection creation rate to 2147483647

290415:20:54.620 [pool-67-thread-3] INFO k.n.SocketServer - [SocketServer listenerType=CONTROLLER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER)

290515:20:54.625 [pool-67-thread-3] INFO o.a.k.s.n.EndpointReadyFutures - authorizerStart completed for endpoint CONTROLLER. Endpoint is now READY.

290615:20:54.627 [pool-67-thread-3] INFO k.s.SharedServer - [SharedServer id=0] Starting SharedServer

290715:20:54.675 [pool-67-thread-3] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs5982689497894266552] Loading producer state till offset 0

290815:20:54.676 [pool-67-thread-3] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs5982689497894266552] Reloading from producer snapshot and rebuilding producer state from offset 0

290915:20:54.676 [pool-67-thread-3] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs5982689497894266552] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0

291015:20:54.694 [pool-67-thread-3] INFO k.r.KafkaMetadataLog$ - Initialized snapshots with IDs SortedSet() from /tmp/kafka-logs5982689497894266552/__cluster_metadata-0

291115:20:54.705 [raft-expiration-reaper] INFO o.a.k.r.TimingWheelExpirationService$ExpiredOperationReaper - [raft-expiration-reaper]: Starting

291215:20:54.718 [pool-67-thread-3] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Reading KRaft snapshot and log as part of the initialization

291315:20:54.720 [pool-67-thread-3] 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])})

291415:20:54.723 [pool-67-thread-3] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Starting request manager with static voters: [localhost:6002 (id: 0 rack: null isFenced: false)]

291515:20:54.726 [pool-67-thread-3] 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=1606, highWatermark=Optional.empty) from null

291615:20:54.798 [pool-67-thread-3] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1606, highWatermark=Optional.empty) from null

291715:20:54.802 [pool-67-thread-3] 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=1146, highWatermark=Optional.empty) from UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1606, highWatermark=Optional.empty)

291815:20:54.803 [pool-67-thread-3] INFO o.a.k.r.QuorumState - [RaftManager id=0] Attempting durable transition to CandidateState(localId=0, localDirectoryId=bfxY4JLWDJqXknmblZ20cw, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1907) from ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1146, highWatermark=Optional.empty)

291915:20:54.808 [pool-67-thread-3] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to CandidateState(localId=0, localDirectoryId=bfxY4JLWDJqXknmblZ20cw, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1907) from ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1146, highWatermark=Optional.empty)

292015:20:54.814 [pool-67-thread-3] INFO o.a.k.r.QuorumState - [RaftManager id=0] Attempting durable transition to Leader(localVoterNode=VoterNode(voterKey=ReplicaKey(id=0, directoryId=bfxY4JLWDJqXknmblZ20cw), 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=bfxY4JLWDJqXknmblZ20cw, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1907)

292115:20:54.815 [pool-67-thread-3] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to Leader(localVoterNode=VoterNode(voterKey=ReplicaKey(id=0, directoryId=bfxY4JLWDJqXknmblZ20cw), 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=bfxY4JLWDJqXknmblZ20cw, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1907)

292215:20:54.833 [kafka-0-raft-outbound-request-thread] INFO o.a.k.r.KafkaNetworkChannel$SendThread - [kafka-0-raft-outbound-request-thread]: Starting

292315:20:54.833 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClientDriver - [kafka-0-raft-io-thread]: Starting

292415:20:54.848 [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 still don't know the high water mark yet.

292515:20:54.850 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for controller quorum voters future

292615:20:54.850 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for controller quorum voters future

292715:20:54.857 [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)]

292815:20:54.863 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Registered the listener org.apache.kafka.image.loader.MetadataLoader@1672530426

292915:20:54.865 [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@1672530426 to 0 since there are no snapshots

293015:20:54.869 [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

293115:20:54.891 [pool-67-thread-3] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task writeNoOpRecord to run every 500 ms

293215:20:54.891 [pool-67-thread-3] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task maybeFenceStaleBroker to run every 1125 ms

293315:20:54.892 [pool-67-thread-3] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task electPreferred to run every 300000 ms

293415:20:54.892 [pool-67-thread-3] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task electUnclean to run every 300000 ms

293515:20:54.892 [pool-67-thread-3] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task expireDelegationTokens to run every 3600000 ms

293615:20:54.892 [pool-67-thread-3] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task generatePeriodicPerformanceMessage to run every 60000 ms

293715:20:54.893 [pool-67-thread-3] INFO o.a.k.c.QuorumController - [QuorumController id=0] Creating new QuorumController with clusterId BJqwkK6mSo6OvprLaTJJCw

293815:20:54.893 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@272237472

293915:20:54.894 [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@272237472 to 0 since there are no snapshots

294015:20:54.898 [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.

294115:20:54.901 [controller-0-ThrottledChannelReaper-Fetch] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Fetch]: Starting

294215:20:54.901 [controller-0-ThrottledChannelReaper-Produce] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Produce]: Starting

294315:20:54.901 [controller-0-ThrottledChannelReaper-Request] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Request]: Starting

294415:20:54.904 [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'.

294515:20:54.905 [controller-0-ThrottledChannelReaper-ControllerMutation] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-ControllerMutation]: Starting

294615:20:54.907 [quorum-controller-0-event-handler] INFO o.a.k.c.OffsetControlManager - [QuorumController id=0] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1.

294715:20:54.908 [quorum-controller-0-event-handler] INFO o.a.k.c.FeatureControlManager - [QuorumController id=0] Replayed a FeatureLevelRecord setting metadata.version to 4.1-IV1

294815:20:54.908 [quorum-controller-0-event-handler] INFO o.a.k.c.OffsetControlManager - [QuorumController id=0] Replayed EndTransactionRecord() at offset 3.

294915:20:54.909 [quorum-controller-0-event-handler] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Activated periodic tasks: electPreferred, electUnclean, expireDelegationTokens, generatePeriodicPerformanceMessage, maybeFenceStaleBroker, writeNoOpRecord

295015:20:54.923 [ExpirationReaper-0-AlterAcls] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-AlterAcls]: Starting

295115:20:54.940 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for the controller metadata publishers to be installed

295215:20:54.941 [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

295315:20:54.943 [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

295415:20:54.943 [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

295515:20:54.943 [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

295615:20:54.945 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for the controller metadata publishers to be installed

295715:20:54.946 [pool-67-thread-3] INFO k.n.SocketServer - [SocketServer listenerType=CONTROLLER, nodeId=0] Enabling request processing.

295815:20:54.957 [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].

295915:20:54.957 [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

296015:20:54.957 [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

296115:20:54.958 [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

296215:20:54.960 [pool-67-thread-3] INFO k.n.DataPlaneAcceptor - Awaiting socket connections on localhost:6002.

296315:20:54.961 [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

296415:20:54.962 [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

296515:20:54.963 [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

296615:20:54.964 [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

296715:20:54.968 [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

296815:20:54.968 [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

296915:20:54.974 [controller-0-to-controller-registration-channel-manager] INFO k.s.NodeToControllerRequestThread - [controller-0-to-controller-registration-channel-manager]: Starting

297015:20:54.975 [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)

297115:20:54.974 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=otvYEWT7TdqjIMfAFNpAYw] initialized channel manager.

297215:20:54.974 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for all of the authorizer futures to be completed

297315:20:54.976 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for all of the authorizer futures to be completed

297415:20:54.976 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for all of the SocketServer Acceptors to be started

297515:20:54.977 [pool-67-thread-3] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for all of the SocketServer Acceptors to be started

297615:20:54.977 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Transition from SHUTDOWN to STARTING

297715:20:54.977 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Starting broker

297815:20:54.983 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=otvYEWT7TdqjIMfAFNpAYw] sendControllerRegistration: attempting to send ControllerRegistrationRequestData(controllerId=0, incarnationId=otvYEWT7TdqjIMfAFNpAYw, 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)])

297915:20:54.989 [broker-0-ThrottledChannelReaper-Fetch] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Fetch]: Starting

298015:20:54.990 [broker-0-ThrottledChannelReaper-Produce] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Produce]: Starting

298115:20:54.991 [broker-0-ThrottledChannelReaper-Request] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Request]: Starting

298215:20:54.992 [broker-0-ThrottledChannelReaper-ControllerMutation] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-ControllerMutation]: Starting

298315:20:55.011 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for controller quorum voters future

298415:20:55.012 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for controller quorum voters future

298515:20:55.014 [broker-0-to-controller-forwarding-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-forwarding-channel-manager]: Starting

298615:20:55.014 [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)

298715:20:55.024 [client-metrics-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [client-metrics-reaper]: Starting

298815:20:55.068 [pool-67-thread-3] INFO k.n.ConnectionQuotas - Updated connection-accept-rate max connection creation rate to 2147483647

298915:20:55.073 [pool-67-thread-3] INFO k.n.SocketServer - [SocketServer listenerType=BROKER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(BROKER)

299015:20:55.083 [quorum-controller-0-event-handler] INFO o.a.k.c.ClusterControlManager - [QuorumController id=0] Replayed RegisterControllerRecord containing ControllerRegistration(id=0, incarnationId=otvYEWT7TdqjIMfAFNpAYw, 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}).

299115:20:55.083 [broker-0-to-controller-alter-partition-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-alter-partition-channel-manager]: Starting

299215:20:55.084 [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)

299315:20:55.088 [broker-0-to-controller-directory-assignments-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-directory-assignments-channel-manager]: Starting

299415:20:55.088 [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)

299515:20:55.104 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=otvYEWT7TdqjIMfAFNpAYw] Our registration has been persisted to the metadata log.

299615:20:55.105 [ExpirationReaper-0-Produce] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-Produce]: Starting

299715:20:55.106 [controller-0-to-controller-registration-channel-manager] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=otvYEWT7TdqjIMfAFNpAYw] RegistrationResponseHandler: controller acknowledged ControllerRegistrationRequest.

299815:20:55.106 [ExpirationReaper-0-Fetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-Fetch]: Starting

299915:20:55.107 [ExpirationReaper-0-DeleteRecords] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-DeleteRecords]: Starting

300015:20:55.107 [ExpirationReaper-0-RemoteFetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-RemoteFetch]: Starting

300115:20:55.109 [ExpirationReaper-0-RemoteListOffsets] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-RemoteListOffsets]: Starting

300215:20:55.109 [ExpirationReaper-0-ShareFetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-ShareFetch]: Starting

300315:20:55.125 [share-coordinator-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [share-coordinator-reaper]: Starting

300415:20:55.146 [share-coordinator-event-processor-0] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [share-coordinator-event-processor-0]: Starting

300515:20:55.151 [persister-state-manager-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [persister-state-manager-reaper]: Starting

300615:20:55.153 [PersisterStateManager] INFO o.a.k.s.s.p.PersisterStateManager$SendThread - [PersisterStateManager]: Starting

300715:20:55.154 [group-coordinator-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [group-coordinator-reaper]: Starting

300815:20:55.165 [group-coordinator-event-processor-0] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-0]: Starting

300915:20:55.165 [group-coordinator-event-processor-1] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-1]: Starting

301015:20:55.165 [group-coordinator-event-processor-2] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-2]: Starting

301115:20:55.166 [group-coordinator-event-processor-3] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-3]: Starting

301215:20:55.182 [pool-67-thread-3] INFO k.l.LogManager - Unable to read the broker epoch in /tmp/kafka-logs5982689497894266552.

301315:20:55.183 [broker-0-to-controller-heartbeat-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-heartbeat-channel-manager]: Starting

301415:20:55.183 [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)

301515:20:55.185 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] Incarnation GynRwrzJSrixNIfOpXiGxA of broker 0 in cluster BJqwkK6mSo6OvprLaTJJCw is now STARTING.

301615:20:55.192 [share-group-lock-timeout-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [share-group-lock-timeout-reaper]: Starting

301715:20:55.196 [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 GynRwrzJSrixNIfOpXiGxA. Generated 0 record(s) to clean up previous incarnations. New broker epoch is 5.

301815:20:55.202 [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=GynRwrzJSrixNIfOpXiGxA, 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=[bfxY4JLWDJqXknmblZ20cw])

301915:20:55.207 [ExpirationReaper-0-AlterAcls] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-AlterAcls]: Starting

302015:20:55.220 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the broker metadata publishers to be installed

302115:20:55.220 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the broker metadata publishers to be installed

302215:20:55.221 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the controller to acknowledge that we are caught up

302315:20:55.221 [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

302415:20:55.221 [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

302515:20:55.224 [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].

302615:20:55.224 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Loading logs from log dirs ArrayBuffer(/tmp/kafka-logs5982689497894266552)

302715:20:55.228 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - No logs found to be loaded in /tmp/kafka-logs5982689497894266552

302815:20:55.230 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] Successfully registered broker 0 with broker epoch 5

302915:20:55.238 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Loaded 0 logs in 11ms

303015:20:55.238 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Starting log cleanup with a period of 300000 ms.

303115:20:55.239 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Starting log flusher with a default period of 9223372036854775807 ms.

303215:20:55.244 [kafka-0-metadata-loader-event-handler] INFO o.a.k.s.i.l.LogCleaner - Starting the log cleaner

303315:20:55.248 [kafka-log-cleaner-thread-0] INFO o.a.k.s.i.l.LogCleaner$CleanerThread - [kafka-log-cleaner-thread-0]: Starting

303415:20:55.254 [LogDirFailureHandler] INFO k.s.ReplicaManager$LogDirFailureHandler - [LogDirFailureHandler]: Starting

303515:20:55.254 [AddPartitionsToTxnSenderThread-0] INFO o.a.k.s.t.AddPartitionsToTxnManager - [AddPartitionsToTxnSenderThread-0]: Starting

303615:20:55.257 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.g.GroupCoordinatorService - [GroupCoordinator id=0] Starting up.

303715:20:55.258 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.g.GroupCoordinatorService - [GroupCoordinator id=0] Startup complete.

303815:20:55.258 [kafka-0-metadata-loader-event-handler] INFO k.c.t.TransactionCoordinator - [TransactionCoordinator id=0] Starting up.

303915:20:55.259 [TxnMarkerSenderThread-0] INFO k.c.t.TransactionMarkerChannelManager - [TxnMarkerSenderThread-0]: Starting

304015:20:55.260 [kafka-0-metadata-loader-event-handler] INFO k.c.t.TransactionCoordinator - [TransactionCoordinator id=0] Startup complete.

304115:20:55.260 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.s.ShareCoordinatorService - [ShareCoordinator id=0] Starting up.

304215:20:55.260 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.s.ShareCoordinatorService - [ShareCoordinator id=0] Startup complete.

304315:20:55.268 [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

304415:20:55.277 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] The broker has caught up. Transitioning from STARTING to RECOVERY.

304515:20:55.277 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the controller to acknowledge that we are caught up

304615:20:55.277 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the initial broker metadata update to be published

304715:20:55.277 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the initial broker metadata update to be published

304815:20:55.279 [pool-67-thread-3] INFO o.a.k.c.c.AbstractConfig - KafkaConfig values:

3049 add.partitions.to.txn.retry.backoff.max.ms = 100

3050 add.partitions.to.txn.retry.backoff.ms = 20

3051 advertised.listeners = BROKER://localhost:6001

3052 alter.config.policy.class.name = null

3053 alter.log.dirs.replication.quota.window.num = 11

3054 alter.log.dirs.replication.quota.window.size.seconds = 1

3055 authorizer.class.name =

3056 auto.create.topics.enable = true

3057 auto.leader.rebalance.enable = true

3058 background.threads = 10

3059 broker.heartbeat.interval.ms = 2000

3060 broker.id = 0

3061 broker.rack = null

3062 broker.session.timeout.ms = 9000

3063 client.quota.callback.class = null

3064 compression.gzip.level = -1

3065 compression.lz4.level = 9

3066 compression.type = producer

3067 compression.zstd.level = 3

3068 connection.failed.authentication.delay.ms = 100

3069 connections.max.idle.ms = 600000

3070 connections.max.reauth.ms = 0

3071 controlled.shutdown.enable = true

3072 controller.listener.names = CONTROLLER

3073 controller.performance.always.log.threshold.ms = 2000

3074 controller.performance.sample.period.ms = 60000

3075 controller.quorum.append.linger.ms = 25

3076 controller.quorum.bootstrap.servers = []

3077 controller.quorum.election.backoff.max.ms = 1000

3078 controller.quorum.election.timeout.ms = 1000

3079 controller.quorum.fetch.timeout.ms = 2000

3080 controller.quorum.request.timeout.ms = 2000

3081 controller.quorum.retry.backoff.ms = 20

3082 controller.quorum.voters = [0@localhost:6002]

3083 controller.quota.window.num = 11

3084 controller.quota.window.size.seconds = 1

3085 controller.socket.timeout.ms = 30000

3086 create.topic.policy.class.name = null

3087 default.replication.factor = 1

3088 delegation.token.expiry.check.interval.ms = 3600000

3089 delegation.token.expiry.time.ms = 86400000

3090 delegation.token.max.lifetime.ms = 604800000

3091 delegation.token.secret.key = null

3092 delete.records.purgatory.purge.interval.requests = 1

3093 delete.topic.enable = true

3094 early.start.listeners = null

3095 fetch.max.bytes = 57671680

3096 fetch.purgatory.purge.interval.requests = 1000

3097 group.consumer.assignors = [uniform, range]

3098 group.consumer.heartbeat.interval.ms = 5000

3099 group.consumer.max.heartbeat.interval.ms = 15000

3100 group.consumer.max.session.timeout.ms = 60000

3101 group.consumer.max.size = 2147483647

3102 group.consumer.migration.policy = bidirectional

3103 group.consumer.min.heartbeat.interval.ms = 5000

3104 group.consumer.min.session.timeout.ms = 45000

3105 group.consumer.regex.refresh.interval.ms = 600000

3106 group.consumer.session.timeout.ms = 45000

3107 group.coordinator.append.linger.ms = 5

3108 group.coordinator.rebalance.protocols = [classic, consumer, streams]

3109 group.coordinator.threads = 4

3110 group.initial.rebalance.delay.ms = 3000

3111 group.max.session.timeout.ms = 1800000

3112 group.max.size = 2147483647

3113 group.min.session.timeout.ms = 6000

3114 group.share.assignors = [simple]

3115 group.share.delivery.count.limit = 5

3116 group.share.enable = false

3117 group.share.heartbeat.interval.ms = 5000

3118 group.share.max.heartbeat.interval.ms = 15000

3119 group.share.max.record.lock.duration.ms = 60000

3120 group.share.max.session.timeout.ms = 60000

3121 group.share.max.share.sessions = 2000

3122 group.share.max.size = 200

3123 group.share.min.heartbeat.interval.ms = 5000

3124 group.share.min.record.lock.duration.ms = 15000

3125 group.share.min.session.timeout.ms = 45000

3126 group.share.partition.max.record.locks = 2000

3127 group.share.persister.class.name = org.apache.kafka.server.share.persister.DefaultStatePersister

3128 group.share.record.lock.duration.ms = 30000

3129 group.share.session.timeout.ms = 45000

3130 group.streams.heartbeat.interval.ms = 5000

3131 group.streams.max.heartbeat.interval.ms = 15000

3132 group.streams.max.session.timeout.ms = 60000

3133 group.streams.max.size = 2147483647

3134 group.streams.max.standby.replicas = 2

3135 group.streams.min.heartbeat.interval.ms = 5000

3136 group.streams.min.session.timeout.ms = 45000

3137 group.streams.num.standby.replicas = 0

3138 group.streams.session.timeout.ms = 45000

3139 initial.broker.registration.timeout.ms = 60000

3140 inter.broker.listener.name = BROKER

3141 internal.metadata.delete.delay.millis = 60000

3142 internal.metadata.log.segment.bytes = null

3143 internal.metadata.max.batch.size.in.bytes = 8388608

3144 internal.metadata.max.fetch.size.in.bytes = 8388608

3145 kafka.metrics.polling.interval.secs = 10

3146 kafka.metrics.reporters = []

3147 leader.imbalance.check.interval.seconds = 300

3148 listener.security.protocol.map = BROKER:PLAINTEXT,CONTROLLER:PLAINTEXT

3149 listeners = BROKER://localhost:6001,CONTROLLER://localhost:6002

3150 log.cleaner.backoff.ms = 15000

3151 log.cleaner.dedupe.buffer.size = 1048577

3152 log.cleaner.delete.retention.ms = 86400000

3153 log.cleaner.enable = true

3154 log.cleaner.io.buffer.load.factor = 0.9

3155 log.cleaner.io.buffer.size = 524288

3156 log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308

3157 log.cleaner.max.compaction.lag.ms = 9223372036854775807

3158 log.cleaner.min.cleanable.ratio = 0.5

3159 log.cleaner.min.compaction.lag.ms = 0

3160 log.cleaner.threads = 1

3161 log.cleanup.policy = [delete]

3162 log.dir = /tmp/kafka-logs

3163 log.dir.failure.timeout.ms = 30000

3164 log.dirs = /tmp/kafka-logs5982689497894266552

3165 log.flush.interval.messages = 1

3166 log.flush.interval.ms = null

3167 log.flush.offset.checkpoint.interval.ms = 60000

3168 log.flush.scheduler.interval.ms = 9223372036854775807

3169 log.flush.start.offset.checkpoint.interval.ms = 60000

3170 log.index.interval.bytes = 4096

3171 log.index.size.max.bytes = 10485760

3172 log.initial.task.delay.ms = 30000

3173 log.local.retention.bytes = -2

3174 log.local.retention.ms = -2

3175 log.message.timestamp.after.max.ms = 3600000

3176 log.message.timestamp.before.max.ms = 9223372036854775807

3177 log.message.timestamp.type = CreateTime

3178 log.preallocate = false

3179 log.retention.bytes = -1

3180 log.retention.check.interval.ms = 300000

3181 log.retention.hours = 168

3182 log.retention.minutes = null

3183 log.retention.ms = null

3184 log.roll.hours = 168

3185 log.roll.jitter.hours = 0

3186 log.roll.jitter.ms = null

3187 log.roll.ms = null

3188 log.segment.bytes = 1073741824

3189 log.segment.delete.delay.ms = 60000

3190 max.connection.creation.rate = 2147483647

3191 max.connections = 2147483647

3192 max.connections.per.ip = 2147483647

3193 max.connections.per.ip.overrides =

3194 max.incremental.fetch.session.cache.slots = 1000

3195 max.request.partition.size.limit = 2000

3196 message.max.bytes = 1048588

3197 metadata.log.dir = null

3198 metadata.log.max.record.bytes.between.snapshots = 20971520

3199 metadata.log.max.snapshot.interval.ms = 3600000

3200 metadata.log.segment.bytes = 1073741824

3201 metadata.log.segment.ms = 604800000

3202 metadata.max.idle.interval.ms = 500

3203 metadata.max.retention.bytes = 104857600

3204 metadata.max.retention.ms = 604800000

3205 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3206 metrics.num.samples = 2

3207 metrics.recording.level = INFO

3208 metrics.sample.window.ms = 30000

3209 min.insync.replicas = 1

3210 node.id = 0

3211 num.io.threads = 8

3212 num.network.threads = 3

3213 num.partitions = 1

3214 num.recovery.threads.per.data.dir = 2

3215 num.replica.alter.log.dirs.threads = null

3216 num.replica.fetchers = 1

3217 offset.metadata.max.bytes = 4096

3218 offsets.commit.timeout.ms = 5000

3219 offsets.load.buffer.size = 5242880

3220 offsets.retention.check.interval.ms = 600000

3221 offsets.retention.minutes = 10080

3222 offsets.topic.compression.codec = 0

3223 offsets.topic.num.partitions = 1

3224 offsets.topic.replication.factor = 1

3225 offsets.topic.segment.bytes = 104857600

3226 principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder

3227 process.roles = [broker, controller]

3228 producer.id.expiration.check.interval.ms = 600000

3229 producer.id.expiration.ms = 86400000

3230 producer.purgatory.purge.interval.requests = 1000

3231 queued.max.request.bytes = -1

3232 queued.max.requests = 500

3233 quota.window.num = 11

3234 quota.window.size.seconds = 1

3235 remote.fetch.max.wait.ms = 500

3236 remote.list.offsets.request.timeout.ms = 30000

3237 remote.log.index.file.cache.total.size.bytes = 1073741824

3238 remote.log.manager.copier.thread.pool.size = 10

3239 remote.log.manager.copy.max.bytes.per.second = 9223372036854775807

3240 remote.log.manager.copy.quota.window.num = 11

3241 remote.log.manager.copy.quota.window.size.seconds = 1

3242 remote.log.manager.expiration.thread.pool.size = 10

3243 remote.log.manager.fetch.max.bytes.per.second = 9223372036854775807

3244 remote.log.manager.fetch.quota.window.num = 11

3245 remote.log.manager.fetch.quota.window.size.seconds = 1

3246 remote.log.manager.task.interval.ms = 30000

3247 remote.log.manager.task.retry.backoff.max.ms = 30000

3248 remote.log.manager.task.retry.backoff.ms = 500

3249 remote.log.manager.task.retry.jitter = 0.2

3250 remote.log.manager.thread.pool.size = 2

3251 remote.log.metadata.custom.metadata.max.bytes = 128

3252 remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager

3253 remote.log.metadata.manager.class.path = null

3254 remote.log.metadata.manager.impl.prefix = rlmm.config.

3255 remote.log.metadata.manager.listener.name = null

3256 remote.log.reader.max.pending.tasks = 100

3257 remote.log.reader.threads = 10

3258 remote.log.storage.manager.class.name = null

3259 remote.log.storage.manager.class.path = null

3260 remote.log.storage.manager.impl.prefix = rsm.config.

3261 remote.log.storage.system.enable = false

3262 replica.fetch.backoff.ms = 1000

3263 replica.fetch.max.bytes = 1048576

3264 replica.fetch.min.bytes = 1

3265 replica.fetch.response.max.bytes = 10485760

3266 replica.fetch.wait.max.ms = 500

3267 replica.high.watermark.checkpoint.interval.ms = 5000

3268 replica.lag.time.max.ms = 30000

3269 replica.selector.class = null

3270 replica.socket.receive.buffer.bytes = 65536

3271 replica.socket.timeout.ms = 30000

3272 replication.quota.window.num = 11

3273 replication.quota.window.size.seconds = 1

3274 request.timeout.ms = 30000

3275 sasl.client.callback.handler.class = null

3276 sasl.enabled.mechanisms = [GSSAPI]

3277 sasl.jaas.config = null

3278 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3279 sasl.kerberos.min.time.before.relogin = 60000

3280 sasl.kerberos.principal.to.local.rules = [DEFAULT]

3281 sasl.kerberos.service.name = null

3282 sasl.kerberos.ticket.renew.jitter = 0.05

3283 sasl.kerberos.ticket.renew.window.factor = 0.8

3284 sasl.login.callback.handler.class = null

3285 sasl.login.class = null

3286 sasl.login.connect.timeout.ms = null

3287 sasl.login.read.timeout.ms = null

3288 sasl.login.refresh.buffer.seconds = 300

3289 sasl.login.refresh.min.period.seconds = 60

3290 sasl.login.refresh.window.factor = 0.8

3291 sasl.login.refresh.window.jitter = 0.05

3292 sasl.login.retry.backoff.max.ms = 10000

3293 sasl.login.retry.backoff.ms = 100

3294 sasl.mechanism.controller.protocol = GSSAPI

3295 sasl.mechanism.inter.broker.protocol = GSSAPI

3296 sasl.oauthbearer.assertion.algorithm = RS256

3297 sasl.oauthbearer.assertion.claim.aud = null

3298 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3299 sasl.oauthbearer.assertion.claim.iss = null

3300 sasl.oauthbearer.assertion.claim.jti.include = false

3301 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3302 sasl.oauthbearer.assertion.claim.sub = null

3303 sasl.oauthbearer.assertion.file = null

3304 sasl.oauthbearer.assertion.private.key.file = null

3305 sasl.oauthbearer.assertion.private.key.passphrase = null

3306 sasl.oauthbearer.assertion.template.file = null

3307 sasl.oauthbearer.client.credentials.client.id = null

3308 sasl.oauthbearer.client.credentials.client.secret = null

3309 sasl.oauthbearer.clock.skew.seconds = 30

3310 sasl.oauthbearer.expected.audience = null

3311 sasl.oauthbearer.expected.issuer = null

3312 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3313 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3314 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3315 sasl.oauthbearer.jwks.endpoint.url = null

3316 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3317 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3318 sasl.oauthbearer.scope = null

3319 sasl.oauthbearer.scope.claim.name = scope

3320 sasl.oauthbearer.sub.claim.name = sub

3321 sasl.oauthbearer.token.endpoint.url = null

3322 sasl.server.callback.handler.class = null

3323 sasl.server.max.receive.size = 524288

3324 security.inter.broker.protocol = PLAINTEXT

3325 security.providers = null

3326 server.max.startup.time.ms = 9223372036854775807

3327 share.coordinator.append.linger.ms = 5

3328 share.coordinator.cold.partition.snapshot.interval.ms = 300000

3329 share.coordinator.load.buffer.size = 5242880

3330 share.coordinator.snapshot.update.records.per.snapshot = 500

3331 share.coordinator.state.topic.compression.codec = 0

3332 share.coordinator.state.topic.min.isr = 2

3333 share.coordinator.state.topic.num.partitions = 50

3334 share.coordinator.state.topic.prune.interval.ms = 300000

3335 share.coordinator.state.topic.replication.factor = 3

3336 share.coordinator.state.topic.segment.bytes = 104857600

3337 share.coordinator.threads = 1

3338 share.coordinator.write.timeout.ms = 5000

3339 share.fetch.purgatory.purge.interval.requests = 1000

3340 socket.connection.setup.timeout.max.ms = 30000

3341 socket.connection.setup.timeout.ms = 10000

3342 socket.listen.backlog.size = 50

3343 socket.receive.buffer.bytes = 102400

3344 socket.request.max.bytes = 104857600

3345 socket.send.buffer.bytes = 102400

3346 ssl.allow.dn.changes = false

3347 ssl.allow.san.changes = false

3348 ssl.cipher.suites = []

3349 ssl.client.auth = none

3350 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3351 ssl.endpoint.identification.algorithm = https

3352 ssl.engine.factory.class = null

3353 ssl.key.password = null

3354 ssl.keymanager.algorithm = SunX509

3355 ssl.keystore.certificate.chain = null

3356 ssl.keystore.key = null

3357 ssl.keystore.location = null

3358 ssl.keystore.password = null

3359 ssl.keystore.type = JKS

3360 ssl.principal.mapping.rules = DEFAULT

3361 ssl.protocol = TLSv1.3

3362 ssl.provider = null

3363 ssl.secure.random.implementation = null

3364 ssl.trustmanager.algorithm = PKIX

3365 ssl.truststore.certificates = null

3366 ssl.truststore.location = null

3367 ssl.truststore.password = null

3368 ssl.truststore.type = JKS

3369 telemetry.max.bytes = 1048576

3370 transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000

3371 transaction.max.timeout.ms = 900000

3372 transaction.partition.verification.enable = true

3373 transaction.remove.expired.transaction.cleanup.interval.ms = 3600000

3374 transaction.state.log.load.buffer.size = 5242880

3375 transaction.state.log.min.isr = 1

3376 transaction.state.log.num.partitions = 50

3377 transaction.state.log.replication.factor = 1

3378 transaction.state.log.segment.bytes = 104857600

3379 transaction.two.phase.commit.enable = false

3380 transactional.id.expiration.ms = 604800000

3381 unclean.leader.election.enable = false

3382 unclean.leader.election.interval.ms = 300000

3383 unstable.api.versions.enable = false

3384 unstable.feature.versions.enable = false

338615:20:55.287 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the broker to be unfenced

338715:20:55.291 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] The broker is in RECOVERY.

338815:20:55.292 [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.

338915:20:55.301 [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=[])

339015:20:55.321 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] The broker has been unfenced. Transitioning from RECOVERY to RUNNING.

339115:20:55.322 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the broker to be unfenced

339215:20:55.323 [pool-67-thread-3] INFO o.a.k.s.n.EndpointReadyFutures - authorizerStart completed for endpoint BROKER. Endpoint is now READY.

339315:20:55.324 [pool-67-thread-3] INFO k.n.SocketServer - [SocketServer listenerType=BROKER, nodeId=0] Enabling request processing.

339415:20:55.324 [pool-67-thread-3] INFO k.n.DataPlaneAcceptor - Awaiting socket connections on localhost:6001.

339515:20:55.325 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for all of the authorizer futures to be completed

339615:20:55.325 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for all of the authorizer futures to be completed

339715:20:55.325 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for all of the SocketServer Acceptors to be started

339815:20:55.325 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for all of the SocketServer Acceptors to be started

339915:20:55.325 [pool-67-thread-3] INFO k.s.BrokerServer - [BrokerServer id=0] Transition from STARTING to STARTED

340015:20:55.350 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3401 acks = -1

3402 batch.size = 16384

3403 bootstrap.servers = [localhost:6001]

3404 buffer.memory = 33554432

3405 client.dns.lookup = use_all_dns_ips

3406 client.id = producer-1

3407 compression.gzip.level = -1

3408 compression.lz4.level = 9

3409 compression.type = none

3410 compression.zstd.level = 3

3411 connections.max.idle.ms = 540000

3412 delivery.timeout.ms = 120000

3413 enable.idempotence = true

3414 enable.metrics.push = true

3415 interceptor.classes = []

3416 key.serializer = class org.apache.kafka.common.serialization.StringSerializer

3417 linger.ms = 5

3418 max.block.ms = 10000

3419 max.in.flight.requests.per.connection = 5

3420 max.request.size = 1048576

3421 metadata.max.age.ms = 300000

3422 metadata.max.idle.ms = 300000

3423 metadata.recovery.rebootstrap.trigger.ms = 300000

3424 metadata.recovery.strategy = rebootstrap

3425 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3426 metrics.num.samples = 2

3427 metrics.recording.level = INFO

3428 metrics.sample.window.ms = 30000

3429 partitioner.adaptive.partitioning.enable = true

3430 partitioner.availability.timeout.ms = 0

3431 partitioner.class = null

3432 partitioner.ignore.keys = false

3433 receive.buffer.bytes = 32768

3434 reconnect.backoff.max.ms = 1000

3435 reconnect.backoff.ms = 50

3436 request.timeout.ms = 30000

3437 retries = 2147483647

3438 retry.backoff.max.ms = 1000

3439 retry.backoff.ms = 1000

3440 sasl.client.callback.handler.class = null

3441 sasl.jaas.config = null

3442 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3443 sasl.kerberos.min.time.before.relogin = 60000

3444 sasl.kerberos.service.name = null

3445 sasl.kerberos.ticket.renew.jitter = 0.05

3446 sasl.kerberos.ticket.renew.window.factor = 0.8

3447 sasl.login.callback.handler.class = null

3448 sasl.login.class = null

3449 sasl.login.connect.timeout.ms = null

3450 sasl.login.read.timeout.ms = null

3451 sasl.login.refresh.buffer.seconds = 300

3452 sasl.login.refresh.min.period.seconds = 60

3453 sasl.login.refresh.window.factor = 0.8

3454 sasl.login.refresh.window.jitter = 0.05

3455 sasl.login.retry.backoff.max.ms = 10000

3456 sasl.login.retry.backoff.ms = 100

3457 sasl.mechanism = GSSAPI

3458 sasl.oauthbearer.assertion.algorithm = RS256

3459 sasl.oauthbearer.assertion.claim.aud = null

3460 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3461 sasl.oauthbearer.assertion.claim.iss = null

3462 sasl.oauthbearer.assertion.claim.jti.include = false

3463 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3464 sasl.oauthbearer.assertion.claim.sub = null

3465 sasl.oauthbearer.assertion.file = null

3466 sasl.oauthbearer.assertion.private.key.file = null

3467 sasl.oauthbearer.assertion.private.key.passphrase = null

3468 sasl.oauthbearer.assertion.template.file = null

3469 sasl.oauthbearer.client.credentials.client.id = null

3470 sasl.oauthbearer.client.credentials.client.secret = null

3471 sasl.oauthbearer.clock.skew.seconds = 30

3472 sasl.oauthbearer.expected.audience = null

3473 sasl.oauthbearer.expected.issuer = null

3474 sasl.oauthbearer.header.urlencode = false

3475 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3476 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3477 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3478 sasl.oauthbearer.jwks.endpoint.url = null

3479 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3480 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3481 sasl.oauthbearer.scope = null

3482 sasl.oauthbearer.scope.claim.name = scope

3483 sasl.oauthbearer.sub.claim.name = sub

3484 sasl.oauthbearer.token.endpoint.url = null

3485 security.protocol = PLAINTEXT

3486 security.providers = null

3487 send.buffer.bytes = 131072

3488 socket.connection.setup.timeout.max.ms = 30000

3489 socket.connection.setup.timeout.ms = 10000

3490 ssl.cipher.suites = null

3491 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3492 ssl.endpoint.identification.algorithm = https

3493 ssl.engine.factory.class = null

3494 ssl.key.password = null

3495 ssl.keymanager.algorithm = SunX509

3496 ssl.keystore.certificate.chain = null

3497 ssl.keystore.key = null

3498 ssl.keystore.location = null

3499 ssl.keystore.password = null

3500 ssl.keystore.type = JKS

3501 ssl.protocol = TLSv1.3

3502 ssl.provider = null

3503 ssl.secure.random.implementation = null

3504 ssl.trustmanager.algorithm = PKIX

3505 ssl.truststore.certificates = null

3506 ssl.truststore.location = null

3507 ssl.truststore.password = null

3508 ssl.truststore.type = JKS

3509 transaction.timeout.ms = 60000

3510 transaction.two.phase.commit.enable = false

3511 transactional.id = null

3512 value.serializer = class org.apache.kafka.common.serialization.StringSerializer

351415:20:55.373 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

351515:20:55.380 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-1] Instantiated an idempotent producer.

351615:20:55.395 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

351715:20:55.395 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

351815:20:55.395 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1768314055394

351915:20:55.410 [data-plane-kafka-request-handler-1] INFO k.s.DefaultAutoTopicCreationManager - Sent auto-creation request for Set(t1) to the active controller.

352015:20:55.416 [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}

352115:20:55.417 [kafka-producer-network-thread | producer-1] INFO o.a.k.c.Metadata - [Producer clientId=producer-1] Cluster ID: BJqwkK6mSo6OvprLaTJJCw

352215:20:55.426 [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

352315:20:55.427 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed TopicRecord for topic t1 with topic ID 1J9IgnO9Sx2R04YbZwKGbQ.

352415:20:55.429 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed PartitionRecord for new partition t1-0 with topic ID 1J9IgnO9Sx2R04YbZwKGbQ and PartitionRegistration(replicas=[0], directories=[bfxY4JLWDJqXknmblZ20cw], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).

352515:20:55.438 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Transitioning 1 partition(s) to local leaders.

352615:20:55.439 [kafka-0-metadata-loader-event-handler] INFO k.s.ReplicaFetcherManager - [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(t1-0)

352715:20:55.441 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Creating new partition t1-0 with topic id 1J9IgnO9Sx2R04YbZwKGbQ.

352815:20:55.445 [quorum-controller-0-event-handler] INFO o.a.k.c.ProducerIdControlManager - [QuorumController id=0] Replaying ProducerIdsRecord ProducerIdsRecord(brokerId=0, brokerEpoch=5, nextProducerId=1000)

352915:20:55.453 [kafka-0-metadata-loader-event-handler] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=t1-0, dir=/tmp/kafka-logs5982689497894266552] Loading producer state till offset 0

353015:20:55.454 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Created log for partition t1-0 in /tmp/kafka-logs5982689497894266552/t1-0 with properties {}

353115:20:55.455 [kafka-0-metadata-loader-event-handler] INFO k.c.Partition - [Partition t1-0 broker=0] No checkpointed highwatermark is found for partition t1-0

353215:20:55.457 [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

353315:20:55.461 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Leader t1-0 with topic id Some(1J9IgnO9Sx2R04YbZwKGbQ) 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.

353415:20:56.425 [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

353515:20:56.458 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

353615:20:56.464 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

353715:20:56.464 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

353815:20:56.464 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

353915:20:56.464 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

354015:20:56.465 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-1 unregistered

354115:20:56.466 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3542 acks = -1

3543 batch.size = 16384

3544 bootstrap.servers = [localhost:6001]

3545 buffer.memory = 33554432

3546 client.dns.lookup = use_all_dns_ips

3547 client.id = producer-2

3548 compression.gzip.level = -1

3549 compression.lz4.level = 9

3550 compression.type = none

3551 compression.zstd.level = 3

3552 connections.max.idle.ms = 540000

3553 delivery.timeout.ms = 120000

3554 enable.idempotence = true

3555 enable.metrics.push = true

3556 interceptor.classes = []

3557 key.serializer = class org.apache.kafka.common.serialization.StringSerializer

3558 linger.ms = 5

3559 max.block.ms = 10000

3560 max.in.flight.requests.per.connection = 5

3561 max.request.size = 1048576

3562 metadata.max.age.ms = 300000

3563 metadata.max.idle.ms = 300000

3564 metadata.recovery.rebootstrap.trigger.ms = 300000

3565 metadata.recovery.strategy = rebootstrap

3566 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3567 metrics.num.samples = 2

3568 metrics.recording.level = INFO

3569 metrics.sample.window.ms = 30000

3570 partitioner.adaptive.partitioning.enable = true

3571 partitioner.availability.timeout.ms = 0

3572 partitioner.class = null

3573 partitioner.ignore.keys = false

3574 receive.buffer.bytes = 32768

3575 reconnect.backoff.max.ms = 1000

3576 reconnect.backoff.ms = 50

3577 request.timeout.ms = 30000

3578 retries = 2147483647

3579 retry.backoff.max.ms = 1000

3580 retry.backoff.ms = 1000

3581 sasl.client.callback.handler.class = null

3582 sasl.jaas.config = null

3583 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3584 sasl.kerberos.min.time.before.relogin = 60000

3585 sasl.kerberos.service.name = null

3586 sasl.kerberos.ticket.renew.jitter = 0.05

3587 sasl.kerberos.ticket.renew.window.factor = 0.8

3588 sasl.login.callback.handler.class = null

3589 sasl.login.class = null

3590 sasl.login.connect.timeout.ms = null

3591 sasl.login.read.timeout.ms = null

3592 sasl.login.refresh.buffer.seconds = 300

3593 sasl.login.refresh.min.period.seconds = 60

3594 sasl.login.refresh.window.factor = 0.8

3595 sasl.login.refresh.window.jitter = 0.05

3596 sasl.login.retry.backoff.max.ms = 10000

3597 sasl.login.retry.backoff.ms = 100

3598 sasl.mechanism = GSSAPI

3599 sasl.oauthbearer.assertion.algorithm = RS256

3600 sasl.oauthbearer.assertion.claim.aud = null

3601 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3602 sasl.oauthbearer.assertion.claim.iss = null

3603 sasl.oauthbearer.assertion.claim.jti.include = false

3604 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3605 sasl.oauthbearer.assertion.claim.sub = null

3606 sasl.oauthbearer.assertion.file = null

3607 sasl.oauthbearer.assertion.private.key.file = null

3608 sasl.oauthbearer.assertion.private.key.passphrase = null

3609 sasl.oauthbearer.assertion.template.file = null

3610 sasl.oauthbearer.client.credentials.client.id = null

3611 sasl.oauthbearer.client.credentials.client.secret = null

3612 sasl.oauthbearer.clock.skew.seconds = 30

3613 sasl.oauthbearer.expected.audience = null

3614 sasl.oauthbearer.expected.issuer = null

3615 sasl.oauthbearer.header.urlencode = false

3616 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3617 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3618 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3619 sasl.oauthbearer.jwks.endpoint.url = null

3620 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3621 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3622 sasl.oauthbearer.scope = null

3623 sasl.oauthbearer.scope.claim.name = scope

3624 sasl.oauthbearer.sub.claim.name = sub

3625 sasl.oauthbearer.token.endpoint.url = null

3626 security.protocol = PLAINTEXT

3627 security.providers = null

3628 send.buffer.bytes = 131072

3629 socket.connection.setup.timeout.max.ms = 30000

3630 socket.connection.setup.timeout.ms = 10000

3631 ssl.cipher.suites = null

3632 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3633 ssl.endpoint.identification.algorithm = https

3634 ssl.engine.factory.class = null

3635 ssl.key.password = null

3636 ssl.keymanager.algorithm = SunX509

3637 ssl.keystore.certificate.chain = null

3638 ssl.keystore.key = null

3639 ssl.keystore.location = null

3640 ssl.keystore.password = null

3641 ssl.keystore.type = JKS

3642 ssl.protocol = TLSv1.3

3643 ssl.provider = null

3644 ssl.secure.random.implementation = null

3645 ssl.trustmanager.algorithm = PKIX

3646 ssl.truststore.certificates = null

3647 ssl.truststore.location = null

3648 ssl.truststore.password = null

3649 ssl.truststore.type = JKS

3650 transaction.timeout.ms = 60000

3651 transaction.two.phase.commit.enable = false

3652 transactional.id = null

3653 value.serializer = class org.apache.kafka.common.serialization.StringSerializer

365515:20:56.466 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

365615:20:56.467 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-2] Instantiated an idempotent producer.

365715:20:56.471 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

365815:20:56.471 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

365915:20:56.471 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1768314056471

366015:20:56.476 [kafka-producer-network-thread | producer-2] INFO o.a.k.c.Metadata - [Producer clientId=producer-2] Cluster ID: BJqwkK6mSo6OvprLaTJJCw

366115:20:56.477 [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

366215:20:56.488 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

366315:20:56.492 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

366415:20:56.492 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

366515:20:56.493 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

366615:20:56.493 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

366715:20:56.493 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-2 unregistered

366815:20:56.494 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3669 acks = -1

3670 batch.size = 16384

3671 bootstrap.servers = [localhost:6001]

3672 buffer.memory = 33554432

3673 client.dns.lookup = use_all_dns_ips

3674 client.id = producer-3

3675 compression.gzip.level = -1

3676 compression.lz4.level = 9

3677 compression.type = none

3678 compression.zstd.level = 3

3679 connections.max.idle.ms = 540000

3680 delivery.timeout.ms = 120000

3681 enable.idempotence = true

3682 enable.metrics.push = true

3683 interceptor.classes = []

3684 key.serializer = class org.apache.kafka.common.serialization.StringSerializer

3685 linger.ms = 5

3686 max.block.ms = 10000

3687 max.in.flight.requests.per.connection = 5

3688 max.request.size = 1048576

3689 metadata.max.age.ms = 300000

3690 metadata.max.idle.ms = 300000

3691 metadata.recovery.rebootstrap.trigger.ms = 300000

3692 metadata.recovery.strategy = rebootstrap

3693 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3694 metrics.num.samples = 2

3695 metrics.recording.level = INFO

3696 metrics.sample.window.ms = 30000

3697 partitioner.adaptive.partitioning.enable = true

3698 partitioner.availability.timeout.ms = 0

3699 partitioner.class = null

3700 partitioner.ignore.keys = false

3701 receive.buffer.bytes = 32768

3702 reconnect.backoff.max.ms = 1000

3703 reconnect.backoff.ms = 50

3704 request.timeout.ms = 30000

3705 retries = 2147483647

3706 retry.backoff.max.ms = 1000

3707 retry.backoff.ms = 1000

3708 sasl.client.callback.handler.class = null

3709 sasl.jaas.config = null

3710 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3711 sasl.kerberos.min.time.before.relogin = 60000

3712 sasl.kerberos.service.name = null

3713 sasl.kerberos.ticket.renew.jitter = 0.05

3714 sasl.kerberos.ticket.renew.window.factor = 0.8

3715 sasl.login.callback.handler.class = null

3716 sasl.login.class = null

3717 sasl.login.connect.timeout.ms = null

3718 sasl.login.read.timeout.ms = null

3719 sasl.login.refresh.buffer.seconds = 300

3720 sasl.login.refresh.min.period.seconds = 60

3721 sasl.login.refresh.window.factor = 0.8

3722 sasl.login.refresh.window.jitter = 0.05

3723 sasl.login.retry.backoff.max.ms = 10000

3724 sasl.login.retry.backoff.ms = 100

3725 sasl.mechanism = GSSAPI

3726 sasl.oauthbearer.assertion.algorithm = RS256

3727 sasl.oauthbearer.assertion.claim.aud = null

3728 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3729 sasl.oauthbearer.assertion.claim.iss = null

3730 sasl.oauthbearer.assertion.claim.jti.include = false

3731 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3732 sasl.oauthbearer.assertion.claim.sub = null

3733 sasl.oauthbearer.assertion.file = null

3734 sasl.oauthbearer.assertion.private.key.file = null

3735 sasl.oauthbearer.assertion.private.key.passphrase = null

3736 sasl.oauthbearer.assertion.template.file = null

3737 sasl.oauthbearer.client.credentials.client.id = null

3738 sasl.oauthbearer.client.credentials.client.secret = null

3739 sasl.oauthbearer.clock.skew.seconds = 30

3740 sasl.oauthbearer.expected.audience = null

3741 sasl.oauthbearer.expected.issuer = null

3742 sasl.oauthbearer.header.urlencode = false

3743 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3744 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3745 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3746 sasl.oauthbearer.jwks.endpoint.url = null

3747 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3748 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3749 sasl.oauthbearer.scope = null

3750 sasl.oauthbearer.scope.claim.name = scope

3751 sasl.oauthbearer.sub.claim.name = sub

3752 sasl.oauthbearer.token.endpoint.url = null

3753 security.protocol = PLAINTEXT

3754 security.providers = null

3755 send.buffer.bytes = 131072

3756 socket.connection.setup.timeout.max.ms = 30000

3757 socket.connection.setup.timeout.ms = 10000

3758 ssl.cipher.suites = null

3759 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3760 ssl.endpoint.identification.algorithm = https

3761 ssl.engine.factory.class = null

3762 ssl.key.password = null

3763 ssl.keymanager.algorithm = SunX509

3764 ssl.keystore.certificate.chain = null

3765 ssl.keystore.key = null

3766 ssl.keystore.location = null

3767 ssl.keystore.password = null

3768 ssl.keystore.type = JKS

3769 ssl.protocol = TLSv1.3

3770 ssl.provider = null

3771 ssl.secure.random.implementation = null

3772 ssl.trustmanager.algorithm = PKIX

3773 ssl.truststore.certificates = null

3774 ssl.truststore.location = null

3775 ssl.truststore.password = null

3776 ssl.truststore.type = JKS

3777 transaction.timeout.ms = 60000

3778 transaction.two.phase.commit.enable = false

3779 transactional.id = null

3780 value.serializer = class org.apache.kafka.common.serialization.StringSerializer

378215:20:56.494 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

378315:20:56.495 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-3] Instantiated an idempotent producer.

378415:20:56.499 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

378515:20:56.499 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

378615:20:56.499 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1768314056499

378715:20:56.504 [kafka-producer-network-thread | producer-3] INFO o.a.k.c.Metadata - [Producer clientId=producer-3] Cluster ID: BJqwkK6mSo6OvprLaTJJCw

378815:20:56.505 [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

378915:20:56.515 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

379015:20:56.518 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

379115:20:56.518 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

379215:20:56.518 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

379315:20:56.518 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

379415:20:56.518 [pool-67-thread-3-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-3 unregistered

379515:20:56.535 [virtual-594] INFO o.a.k.c.c.AbstractConfig - ConsumerConfig values:

3796 allow.auto.create.topics = true

3797 auto.commit.interval.ms = 5000

3798 auto.offset.reset = earliest

3799 bootstrap.servers = [localhost:6001]

3800 check.crcs = true

3801 client.dns.lookup = use_all_dns_ips

3802 client.id = consumer-g1-1

3803 client.rack =

3804 connections.max.idle.ms = 540000

3805 default.api.timeout.ms = 60000

3806 enable.auto.commit = false

3807 enable.metrics.push = true

3808 exclude.internal.topics = true

3809 fetch.max.bytes = 52428800

3810 fetch.max.wait.ms = 500

3811 fetch.min.bytes = 1

3812 group.id = g1

3813 group.instance.id = null

3814 group.protocol = classic

3815 group.remote.assignor = null

3816 heartbeat.interval.ms = 3000

3817 interceptor.classes = []

3818 internal.leave.group.on.close = true

3819 internal.throw.on.fetch.stable.offset.unsupported = false

3820 isolation.level = read_uncommitted

3821 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

3822 max.partition.fetch.bytes = 1048576

3823 max.poll.interval.ms = 300000

3824 max.poll.records = 500

3825 metadata.max.age.ms = 300000

3826 metadata.recovery.rebootstrap.trigger.ms = 300000

3827 metadata.recovery.strategy = rebootstrap

3828 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3829 metrics.num.samples = 2

3830 metrics.recording.level = INFO

3831 metrics.sample.window.ms = 30000

3832 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]

3833 receive.buffer.bytes = 65536

3834 reconnect.backoff.max.ms = 1000

3835 reconnect.backoff.ms = 50

3836 request.timeout.ms = 30000

3837 retry.backoff.max.ms = 1000

3838 retry.backoff.ms = 100

3839 sasl.client.callback.handler.class = null

3840 sasl.jaas.config = null

3841 sasl.kerberos.kinit.cmd = /usr/bin/kinit

3842 sasl.kerberos.min.time.before.relogin = 60000

3843 sasl.kerberos.service.name = null

3844 sasl.kerberos.ticket.renew.jitter = 0.05

3845 sasl.kerberos.ticket.renew.window.factor = 0.8

3846 sasl.login.callback.handler.class = null

3847 sasl.login.class = null

3848 sasl.login.connect.timeout.ms = null

3849 sasl.login.read.timeout.ms = null

3850 sasl.login.refresh.buffer.seconds = 300

3851 sasl.login.refresh.min.period.seconds = 60

3852 sasl.login.refresh.window.factor = 0.8

3853 sasl.login.refresh.window.jitter = 0.05

3854 sasl.login.retry.backoff.max.ms = 10000

3855 sasl.login.retry.backoff.ms = 100

3856 sasl.mechanism = GSSAPI

3857 sasl.oauthbearer.assertion.algorithm = RS256

3858 sasl.oauthbearer.assertion.claim.aud = null

3859 sasl.oauthbearer.assertion.claim.exp.seconds = 300

3860 sasl.oauthbearer.assertion.claim.iss = null

3861 sasl.oauthbearer.assertion.claim.jti.include = false

3862 sasl.oauthbearer.assertion.claim.nbf.seconds = 60

3863 sasl.oauthbearer.assertion.claim.sub = null

3864 sasl.oauthbearer.assertion.file = null

3865 sasl.oauthbearer.assertion.private.key.file = null

3866 sasl.oauthbearer.assertion.private.key.passphrase = null

3867 sasl.oauthbearer.assertion.template.file = null

3868 sasl.oauthbearer.client.credentials.client.id = null

3869 sasl.oauthbearer.client.credentials.client.secret = null

3870 sasl.oauthbearer.clock.skew.seconds = 30

3871 sasl.oauthbearer.expected.audience = null

3872 sasl.oauthbearer.expected.issuer = null

3873 sasl.oauthbearer.header.urlencode = false

3874 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

3875 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

3876 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

3877 sasl.oauthbearer.jwks.endpoint.url = null

3878 sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever

3879 sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator

3880 sasl.oauthbearer.scope = null

3881 sasl.oauthbearer.scope.claim.name = scope

3882 sasl.oauthbearer.sub.claim.name = sub

3883 sasl.oauthbearer.token.endpoint.url = null

3884 security.protocol = PLAINTEXT

3885 security.providers = null

3886 send.buffer.bytes = 131072

3887 session.timeout.ms = 45000

3888 share.acknowledgement.mode = implicit

3889 socket.connection.setup.timeout.max.ms = 30000

3890 socket.connection.setup.timeout.ms = 10000

3891 ssl.cipher.suites = null

3892 ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

3893 ssl.endpoint.identification.algorithm = https

3894 ssl.engine.factory.class = null

3895 ssl.key.password = null

3896 ssl.keymanager.algorithm = SunX509

3897 ssl.keystore.certificate.chain = null

3898 ssl.keystore.key = null

3899 ssl.keystore.location = null

3900 ssl.keystore.password = null

3901 ssl.keystore.type = JKS

3902 ssl.protocol = TLSv1.3

3903 ssl.provider = null

3904 ssl.secure.random.implementation = null

3905 ssl.trustmanager.algorithm = PKIX

3906 ssl.truststore.certificates = null

3907 ssl.truststore.location = null

3908 ssl.truststore.password = null

3909 ssl.truststore.type = JKS

3910 value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

391215:20:56.545 [virtual-594] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

391315:20:56.580 [virtual-594] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

391415:20:56.580 [virtual-594] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

391515:20:56.580 [virtual-594] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1768314056580

391615:20:56.602 [virtual-601] INFO o.a.k.c.c.i.ClassicKafkaConsumer - [Consumer clientId=consumer-g1-1, groupId=g1] Subscribed to topic(s): t1

391715:20:56.609 [virtual-601] INFO o.a.k.c.Metadata - [Consumer clientId=consumer-g1-1, groupId=g1] Cluster ID: BJqwkK6mSo6OvprLaTJJCw

391815:20:56.610 [data-plane-kafka-request-handler-7] INFO k.s.DefaultAutoTopicCreationManager - Sent auto-creation request for Set(__consumer_offsets) to the active controller.

391915:20:56.614 [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

392015:20:56.615 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed TopicRecord for topic __consumer_offsets with topic ID z1FpZ7rqTseT7ZJlr_4QUQ.

392115:20:56.616 [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

392215:20:56.616 [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

392315:20:56.616 [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

392415:20:56.616 [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 z1FpZ7rqTseT7ZJlr_4QUQ and PartitionRegistration(replicas=[0], directories=[bfxY4JLWDJqXknmblZ20cw], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).

392515:20:56.643 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Transitioning 1 partition(s) to local leaders.

392615:20:56.643 [kafka-0-metadata-loader-event-handler] INFO k.s.ReplicaFetcherManager - [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(__consumer_offsets-0)

392715:20:56.644 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Creating new partition __consumer_offsets-0 with topic id z1FpZ7rqTseT7ZJlr_4QUQ.

392815:20:56.646 [kafka-0-metadata-loader-event-handler] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__consumer_offsets-0, dir=/tmp/kafka-logs5982689497894266552] Loading producer state till offset 0

392915:20:56.647 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Created log for partition __consumer_offsets-0 in /tmp/kafka-logs5982689497894266552/__consumer_offsets-0 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}

393015:20:56.647 [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

393115:20:56.647 [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

393215:20:56.647 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Leader __consumer_offsets-0 with topic id Some(z1FpZ7rqTseT7ZJlr_4QUQ) 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.

393315:20:56.649 [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

393415:20:56.656 [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

393515:20:56.670 [group-coordinator-event-processor-0] 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.

393615:20:56.710 [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)

393715:20:56.712 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] (Re-)joining group

393815:20:56.723 [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-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b and requesting the member to rejoin with this id.

393915:20:56.724 [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-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b

394015:20:56.724 [virtual-601] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] (Re-)joining group

394115:20:56.728 [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-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b joins group g1 in Empty state. Adding to the group now.

394215:20:56.729 [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-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b with group instance id null; client reason: need to re-join with the given member-id: consumer-g1-1-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b).

394315:20:59.730 [group-coordinator-event-processor-3] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Stabilized group g1 generation 1 with 1 members.

394415:20:59.733 [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-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b', protocol='range'}

394515:20:59.739 [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-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b=Assignment(partitions=[t1-0])}

394615:20:59.742 [group-coordinator-event-processor-3] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Assignment received from leader consumer-g1-1-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b for group g1 for generation 1. The group has 1 members, 0 of which are static.

394715:20:59.751 [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-4a4189c5-1baa-4a90-b2cb-7ccfa42d4f1b', protocol='range'}

394815:20:59.751 [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])

394915:20:59.753 [virtual-601] INFO o.a.k.c.c.i.ConsumerRebalanceListenerInvoker - [Consumer clientId=consumer-g1-1, groupId=g1] Adding newly assigned partitions: [t1-0]

395015:20:59.760 [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

395115:20:59.771 [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}}.

395215:21:00.059 [virtual-594] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3953 acks = -1

3954 batch.size = 16384

3955 bootstrap.servers = [localhost:6001]

3956 buffer.memory = 33554432

3957 client.dns.lookup = use_all_dns_ips

3958 client.id = producer-4

3959 compression.gzip.level = -1

3960 compression.lz4.level = 9

3961 compression.type = none

3962 compression.zstd.level = 3

3963 connections.max.idle.ms = 540000

3964 delivery.timeout.ms = 120000

3965 enable.idempotence = true

3966 enable.metrics.push = true

3967 interceptor.classes = []

3968 key.serializer = class org.apache.kafka.common.serialization.StringSerializer

3969 linger.ms = 5

3970 max.block.ms = 10000

3971 max.in.flight.requests.per.connection = 5

3972 max.request.size = 1048576

3973 metadata.max.age.ms = 300000

3974 metadata.max.idle.ms = 300000

3975 metadata.recovery.rebootstrap.trigger.ms = 300000

3976 metadata.recovery.strategy = rebootstrap

3977 metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]

3978 metrics.num.samples = 2

3979 metrics.recording.level = INFO

3980 metrics.sample.window.ms = 30000

3981 partitioner.adaptive.partitioning.enable = true

3982 partitioner.availability.timeout.ms = 0

3983 partitioner.class = null

3984 partitioner.ignore.keys = false

3985 receive.buffer.bytes = 32768

3986 reconnect.backoff.max.ms = 1000

3987 reconnect.backoff.ms = 50

3988 request.timeout.ms = 30000

3989 retries = 2147483647

3990 retry.backoff.max.ms = 1000

3991 retry.backoff.ms = 1000