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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

92OpenCB::Limitting incorrect crossVersions List(2.12.20) -> List(3.7.4) in cron/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 Dec 4, 2025, 2:24:05 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/channels/SourceOps.scala]

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

508[info] [patched file /build/repo/core/src/test/scala/ox/flow/FlowOpsForeachTest.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/KafkaFlow.scala]

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

557[info] [patched file /build/repo/kafka/src/main/scala/ox/kafka/kafkaOffsetCommit.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": 17277, "warnings": 0, "errors": 0, "sourceVersion": "3.7-migration"},

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

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

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

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

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

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

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

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

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

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

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

624 "test-compile": {"status": "ok", "tookMs": 1606, "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: 120 s (0:02:00.0), completed Dec 4, 2025, 2:26:05 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 11ec849] 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-RC3

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

652Execute tests: true

653sbt project found:

654No prepare script found for project softwaremill/ox

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

656Scala version: 3.8.0-RC3

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

713[info] Switching Scala version on:

714[info] flowReactiveStreams (3.8.0-RC3)

715[info] documentation (3.8.0-RC3)

716[info] cron (3.8.0-RC3)

717[info] * rootProject (3.8.0-RC3)

718[info] mdcLogback (3.8.0-RC3)

719[info] kafka (3.8.0-RC3)

720[info] core (3.8.0-RC3)

721[info] otelContext (3.8.0-RC3)

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 Dec 4, 2025, 2:26:16 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-RC3/classes ...

820[info] done compiling

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

826[info] done compiling

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

828[info] done compiling

82914:26:48.132 [pool-28-thread-2] 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-RC3/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[2025-12-04T13:27:32.663821899Z] [24] catch

1078[2025-12-04T13:27:32.964084004Z] [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[2025-12-04T13:27:38.991916165Z] [24] in f

1089[info] - should do nothing

1090[2025-12-04T13:27:38.992960269Z] [24] in callback: boom!

1091[2025-12-04T13:27:38.993036713Z] [24] in catch: boom!

1094[2025-12-04T13:27:38.993635824Z] [24] 42

1095[2025-12-04T13:27:38.993724150Z] [24] after

1097[2025-12-04T13:27:38.994775047Z] [24] in catch: boom! 1

1098[2025-12-04T13:27:38.996385502Z] [24] Adding

1099[2025-12-04T13:27:38.996482293Z] [24] Got: 3

1101[info] pipe

1102[info] - should work

1103[info] tap

1104some label: 10

1105[info] - should work

1106[info] debug as extension

1107[info] - should work

1108[info] debug as top-level method

1109x.+(1) = 11

1110[info] - should work

1111[info] FlowOpsLastTest:

1112[info] last

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

1116[info] FlowOpsFailedTest:

1117[info] failed

1118[info] - should fail on receive

1119[info] FlowOpsFlattenTest:

1120[info] flatten

1121[info] - should flatten nested flows

1122[info] WeightedHeapTest:

1123[info] WeightedHeap

1124[info] - should allow inserting elements with weights

1125[info] - should allow extracting the minimum element

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

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

1128[info] - should handle empty heaps correctly

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

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

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

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

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

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

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

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

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

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

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

1141[info] FlowOpsMapConcatTest:

1142[info] mapConcat

1143[info] - should unfold iterables

1144[info] - should transform elements

1145[info] - should handle empty lists

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

1147[info] FlowOpsPipeToTest:

1148[info] - should pipe one source to another

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

1150[info] FlowOpsRecoverTest:

1151[info] Flow.recover

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

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

1159[info] - should work with empty flow

1161[info] FlowOpsMapStatefulTest:

1162[info] mapStateful

1163[info] - should zip with index

1164[info] - should calculate a running total

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

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

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

1168[info] FlowOpsMapTest:

1169[info] map

1170[info] - should map over a source

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

1172[info] ForkTest:

1173[info] fork

1174[2025-12-04T13:27:39.230946505Z] [24] main mid

1175[2025-12-04T13:27:39.731259601Z] [435] f1 complete

1176[2025-12-04T13:27:40.231298496Z] [436] f2 complete

1177[2025-12-04T13:27:40.231559635Z] [24] result = 11

1178[info] - should run two forks concurrently

1179[2025-12-04T13:27:40.234441081Z] [438] f2 complete

1180[2025-12-04T13:27:40.234592294Z] [437] f1 complete

1181[2025-12-04T13:27:40.234755457Z] [24] result = 11

1182[info] - should allow nested forks

1183[2025-12-04T13:27:40.236288684Z] [24] main mid

1184[2025-12-04T13:27:40.736813688Z] [439] f1 complete

1185[2025-12-04T13:27:40.737053921Z] [24] result = 5

1186[2025-12-04T13:27:40.737237922Z] [440] f2 interrupted

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

1188[2025-12-04T13:27:40.740616026Z] [444] in fork

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

1190[2025-12-04T13:27:40.842449471Z] [447] in fork

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

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

1194[info] FlowOpsIntersperseTest:

1195[info] Flow.intersperse

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

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

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

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

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

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

1202[info] FlowOpsScanTest:

1203[info] scan

1204[info] - should scan the empty flow

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

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

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

1208[info] FlowOpsUsingSinkTest:

1209[info] usingSink

1210[info] - should send the passed elements

1211[info] FlowOpsTakeTest:

1212[info] take

1213[info] - should take from a simple flow

1214[info] - should take from an async flow

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

1216[info] EitherTest:

1217[info] either

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

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

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

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

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

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

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

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

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

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

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

1232[info] - should work when combined with mapPar

1233[info] - should not allow nesting of eithers

1234[info] orThrow

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

1237[info] catching

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

1243[info] FlowIOOpsTest:

1244[info] asInputStream

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

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

1247[info] - should correctly track available bytes

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

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

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

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

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

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

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

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

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

1258[info] toOutputStream

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

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

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

1262[info] - should handle an empty Source

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

1264[info] - should close the OutputStream on error

1265[info] toFile

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

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

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

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

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

1271[info] - should handle an empty source

1275[info] FlowOpsConcatPrependTest:

1276[info] concat

1277[info] - should concat other source

1278[info] prepend

1279[info] - should prepend other source

1280[info] FlowTextOpsTest:

1281[info] linesUtf8

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

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

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

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

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

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

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

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

1290[info] lines(charset)

1291zażółć

1292gęślą

1293jaźń

1294[info] - should decode lines with specified charset

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

1296[info] decodeStringUtf8

1297[info] - should decode a simple string

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

1299[info] - should handle an empty Source

1300[info] - should handle partial BOM

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

1302[info] - should handle empty chunks

1303[info] encodeUtf8

1304[info] - should handle empty String

1305[info] - should encode a string

1306[info] FlowOpsZipWithIndexTest:

1307[info] zipWithIndex

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

1309[info] - should zip flow with index

1310[info] ResourceTest:

1311[info] useInScope

1312[2025-12-04T13:27:41.070133576Z] [24] allocate

1313[2025-12-04T13:27:41.070693161Z] [550] release 1

1314[info] - should release resources after allocation

1315[2025-12-04T13:27:41.072259625Z] [24] allocate 1

1316[2025-12-04T13:27:41.072999120Z] [24] allocate 2

1317[2025-12-04T13:27:41.073367850Z] [551] release 2

1318[2025-12-04T13:27:41.073463339Z] [551] release 1

1319[info] - should release resources in reverse order

1320[2025-12-04T13:27:41.075435210Z] [24] allocate 1

1321[2025-12-04T13:27:41.075941576Z] [24] allocate 2

1322[2025-12-04T13:27:41.076757463Z] [552] release 2

1323[2025-12-04T13:27:41.076910009Z] [552] release 1

1326[2025-12-04T13:27:41.078925993Z] [24] allocate 1

1327[2025-12-04T13:27:41.079397104Z] [24] allocate 2

1328[2025-12-04T13:27:41.079908985Z] [553] release 2

1329[2025-12-04T13:27:41.080073433Z] [553] release 1

1332[2025-12-04T13:27:41.082180255Z] [24] allocate 1

1333[2025-12-04T13:27:41.082672566Z] [24] allocate 2

1334[2025-12-04T13:27:41.082916323Z] [554] release 2

1335[2025-12-04T13:27:41.083388276Z] [554] release 1

1338[2025-12-04T13:27:41.085214485Z] [24] in scope

1339[2025-12-04T13:27:41.085527641Z] [555] release

1340[info] - should release registered resources

1341[2025-12-04T13:27:41.086657556Z] [24] allocate

1342[2025-12-04T13:27:41.086775637Z] [24] in scope

1343[2025-12-04T13:27:41.087619227Z] [556] release

1344[info] - should use a resource

1345[2025-12-04T13:27:41.088698036Z] [24] allocate

1346[2025-12-04T13:27:41.088792192Z] [24] in scope

1347[2025-12-04T13:27:41.089456606Z] [557] release

1348[info] - should use a closeable resource

1349[2025-12-04T13:27:41.090443564Z] [24] allocate

1350[2025-12-04T13:27:41.090533592Z] [24] in scope

1351[2025-12-04T13:27:41.091331185Z] [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[2025-12-04T13:27:49.710952822Z] [1917] done

1469[2025-12-04T13:27:49.710952785Z] [1916] 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[2025-12-04T13:27:58.019553368Z] [2410] started

1623[2025-12-04T13:27:58.119925082Z] [2410] interrupted

1624[2025-12-04T13:27:58.620357424Z] [2410] interrupted done

1625[2025-12-04T13:27:58.620713275Z] [2408] cancel done

1626[info] - should block until the fork completes

1627[2025-12-04T13:27:59.623550949Z] [2411] cancel done

1628[2025-12-04T13:27:59.725517185Z] [2416] interrupted

1629[2025-12-04T13:27:59.825883273Z] [2416] interrupted done

1630[2025-12-04T13:27:59.826133729Z] [2414] cancel done

1631[2025-12-04T13:27:59.926770786Z] [2417] cancel done

1632[2025-12-04T13:28:00.028619422Z] [2422] interrupted

1633[2025-12-04T13:28:00.128956355Z] [2422] interrupted done

1634[2025-12-04T13:28:00.129147310Z] [2420] cancel done

1635[2025-12-04T13:28:00.229777253Z] [2423] cancel done

1636[2025-12-04T13:28:00.331686147Z] [2428] interrupted

1637[2025-12-04T13:28:00.432059901Z] [2428] interrupted done

1638[2025-12-04T13:28:00.432294891Z] [2426] cancel done

1639[2025-12-04T13:28:00.532906759Z] [2429] cancel done

1640[2025-12-04T13:28:00.634749330Z] [2434] interrupted

1641[2025-12-04T13:28:00.735092907Z] [2434] interrupted done

1642[2025-12-04T13:28:00.735310807Z] [2432] cancel done

1643[2025-12-04T13:28:00.835926511Z] [2435] cancel done

1644[2025-12-04T13:28:00.937811771Z] [2440] interrupted

1645[2025-12-04T13:28:01.038172418Z] [2440] interrupted done

1646[2025-12-04T13:28:01.038389838Z] [2438] cancel done

1647[2025-12-04T13:28:01.139026330Z] [2441] cancel done

1648[2025-12-04T13:28:01.240926291Z] [2446] interrupted

1649[2025-12-04T13:28:01.341276971Z] [2446] interrupted done

1650[2025-12-04T13:28:01.341502991Z] [2444] cancel done

1651[2025-12-04T13:28:01.442102435Z] [2447] cancel done

1652[2025-12-04T13:28:01.543958252Z] [2452] interrupted

1653[2025-12-04T13:28:01.644303782Z] [2452] interrupted done

1654[2025-12-04T13:28:01.644516890Z] [2450] cancel done

1655[2025-12-04T13:28:01.745176598Z] [2453] cancel done

1656[2025-12-04T13:28:01.847029799Z] [2458] interrupted

1657[2025-12-04T13:28:01.947322950Z] [2458] interrupted done

1658[2025-12-04T13:28:01.947522193Z] [2456] cancel done

1659[2025-12-04T13:28:02.048140811Z] [2459] cancel done

1660[2025-12-04T13:28:02.150038730Z] [2464] interrupted

1661[2025-12-04T13:28:02.250411560Z] [2464] interrupted done

1662[2025-12-04T13:28:02.250672809Z] [2462] cancel done

1663[2025-12-04T13:28:02.351348798Z] [2465] cancel done

1664[2025-12-04T13:28:02.453244431Z] [2470] interrupted

1665[2025-12-04T13:28:02.553628199Z] [2470] interrupted done

1666[2025-12-04T13:28:02.553895769Z] [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[2025-12-04T13:28:02.757891992Z] [2471] cancel done

1690[2025-12-04T13:28:03.258236821Z] [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[2025-12-04T13:28:05.390270778Z] [2505] 3

1734[2025-12-04T13:28:05.390237974Z] [2502] 0

1735[2025-12-04T13:28:05.390257260Z] [2503] 1

1736[2025-12-04T13:28:05.390225137Z] [2504] 2

1737[2025-12-04T13:28:05.390317099Z] [2506] 4

1738[2025-12-04T13:28:05.490748771Z] [2509] 7

1739[2025-12-04T13:28:05.490747551Z] [2508] 6

1740[2025-12-04T13:28:05.490732245Z] [2507] 5

1741[2025-12-04T13:28:05.490777567Z] [2510] 8

1742[2025-12-04T13:28:05.490830830Z] [2511] 9

1743[2025-12-04T13:28:05.591222059Z] [2512] 10

1744[2025-12-04T13:28:05.591222102Z] [2513] 11

1745[2025-12-04T13:28:05.591263301Z] [2515] 13

1746[2025-12-04T13:28:05.591253791Z] [2514] 12

1747[2025-12-04T13:28:05.591837163Z] [2516] 14

1748[2025-12-04T13:28:05.691783485Z] [2519] 17

1749[2025-12-04T13:28:05.691765741Z] [2518] 16

1750[2025-12-04T13:28:05.691729897Z] [2517] 15

1751[info] - should run computations in parallel

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

1754[2025-12-04T13:28:06.027689821Z] [24] catch

1755[2025-12-04T13:28:06.327877498Z] [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[2025-12-04T13:28:50.673746566Z] [24] catch

1856[2025-12-04T13:28:50.973910020Z] [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[2025-12-04T13:28:51.093163434Z] [6025] b

1875[2025-12-04T13:28:51.193175700Z] [6024] a

1876[2025-12-04T13:28:51.193475625Z] [24] done

1877[info] - should run computations in parallel

1879[2025-12-04T13:28:51.295868777Z] [24] catch

1880[2025-12-04T13:28:51.596085339Z] [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[2025-12-04T13:28:52.302125423Z] [6041] x

1885[2025-12-04T13:28:52.302118537Z] [6040] x

1887[2025-12-04T13:28:52.312910913Z] [24] catch

1888[2025-12-04T13:28:52.613097348Z] [24] all done

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

1890[info] parEither

1891[2025-12-04T13:28:52.714906538Z] [6047] b

1892[2025-12-04T13:28:52.814888176Z] [6046] a

1893[2025-12-04T13:28:52.815644615Z] [24] done

1894[info] - should run computations in parallel

1896[2025-12-04T13:28:53.217653086Z] [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[2025-12-04T13:28:54.592739935Z] [24] timeout

1948[2025-12-04T13:28:54.592865771Z] [24] done

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

1950[2025-12-04T13:28:57.094322330Z] [6112] no timeout

1951[2025-12-04T13:28:57.094702512Z] [24] done

1952[info] - should not interrupt a short computation

1953[info] timeoutOption

1954[2025-12-04T13:29:00.096547276Z] [24] done: None

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

1956[info] race

1957[2025-12-04T13:29:02.598546768Z] [6117] fast

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

1959[2025-12-04T13:29:04.101094086Z] [6118] fast

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

1961[2025-12-04T13:29:05.303296531Z] [6120] error

1962[2025-12-04T13:29:05.603322219Z] [6121] slow

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

1967[info] raceEither

1968[2025-12-04T13:29:07.209979541Z] [6131] error

1969[2025-12-04T13:29:07.509972075Z] [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[2025-12-04T13:29:09.258459266Z] [24] catch

1987[2025-12-04T13:29:09.558665374Z] [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[2025-12-04T13:29:09.667719195Z] [6343] b

2000[2025-12-04T13:29:09.767617435Z] [6342] a

2001[2025-12-04T13:29:09.767831869Z] [24] done

2002[info] - should wait until all forks complete

2003[2025-12-04T13:29:09.869452024Z] [6346] b

2004[2025-12-04T13:29:09.869800173Z] [24] done

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

2006[2025-12-04T13:29:09.971585374Z] [6350] b

2007[2025-12-04T13:29:10.072001212Z] [24] done

2009[2025-12-04T13:29:10.273913339Z] [24] done

2011[2025-12-04T13:29:10.375585412Z] [6356] b

2012[2025-12-04T13:29:10.575317738Z] [6354] a

2013[2025-12-04T13:29:10.575629249Z] [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] [12/04/2025 14:29:11.366] [] [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] [12/04/2025 14:29:11.615] [] [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] [12/04/2025 14:29:11.655] [] [CoordinatedShutdown(pekko://test)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason]

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

2079[INFO] [12/04/2025 14:29:11.937] [] [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[2025-12-04T13:29:27.800450645Z] [208016] done

2231[2025-12-04T13:29:27.800450647Z] [208015] done

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

2234[2025-12-04T13:29:28.205018992Z] [208022] 1

2235[2025-12-04T13:29:28.205014571Z] [208023] 2

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

2237[2025-12-04T13:29:28.619118241Z] [208029] done

2238[2025-12-04T13:29:28.619125838Z] [208030] 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[2025-12-04T13:29:30.226705446Z] [24] timeout

2245[2025-12-04T13:29:30.226833956Z] [24] done

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

2248[2025-12-04T13:29:32.329400900Z] [208046] no timeout

2249[2025-12-04T13:29:32.329856343Z] [24] done

2250[info] - should not interrupt a short computation

2251[2025-12-04T13:29:34.731369387Z] [208048] 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[2025-12-04T13:29:38.993543001Z] [24] main mid

2478[2025-12-04T13:29:39.094333724Z] [313241] In f1 = x

2479[2025-12-04T13:29:39.094582647Z] [24] result = a

2480[2025-12-04T13:29:39.194609734Z] [313243] In f3 = z

2481[2025-12-04T13:29:39.194844962Z] [24] result = a

2482[info] - should properly propagate values using supervisedWhere

2483[2025-12-04T13:29:39.196345791Z] [24] main mid

2484[2025-12-04T13:29:39.296539638Z] [313244] In f1 = x

2485[2025-12-04T13:29:39.296724869Z] [24] result = a

2486[2025-12-04T13:29:39.397280021Z] [313246] In f3 = z

2487[2025-12-04T13:29:39.397523763Z] [24] result = a

2488[info] - should properly propagate values using unsupervisedWhere

2489[2025-12-04T13:29:39.399215525Z] [313248] nested1 = x

2490[2025-12-04T13:29:39.399744037Z] [313249] nested2 = x

2491[info] - should propagate values across multiple scopes

2492[2025-12-04T13:29:39.399861253Z] [24] outer = a

2493[info] - should propagate errors from forks created within local values

2494[2025-12-04T13:29:39.401613489Z] [24] v1

2495[2025-12-04T13:29:39.401986738Z] [24] v2

2497[2025-12-04T13:29:39.402244177Z] [24] v1

2499[2025-12-04T13:29:39.402693408Z] [24] v1_1

2500[2025-12-04T13:29:39.402753781Z] [24] v2_1

2501[2025-12-04T13:29:39.403198784Z] [24] v1_2

2502[2025-12-04T13:29:39.403255460Z] [24] v2_2

2503[2025-12-04T13:29:39.403301226Z] [24] v1_1

2504[2025-12-04T13:29:39.403750339Z] [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-RC3/classes ...

2539[info] done compiling

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

2559[info] done compiling

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

2561[info] done compiling

256214:29:51.048 [pool-67-thread-7] 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-logs7572554700115704093

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

290014:29:51.266 [pool-67-thread-7] INFO k.u.Log4jControllerRegistration$ - Registered `kafka:type=kafka.Log4jController` MBean

290114:29:51.310 [pool-67-thread-7] INFO i.g.e.EmbeddedKafka$ - [KafkaRaftServer nodeId=0] Rewriting /tmp/kafka-logs7572554700115704093/meta.properties

290214:29:51.363 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Starting controller

290314:29:51.700 [pool-67-thread-7] INFO k.n.ConnectionQuotas - Updated connection-accept-rate max connection creation rate to 2147483647

290414:29:51.726 [pool-67-thread-7] INFO k.n.SocketServer - [SocketServer listenerType=CONTROLLER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER)

290514:29:51.731 [pool-67-thread-7] INFO o.a.k.s.n.EndpointReadyFutures - authorizerStart completed for endpoint CONTROLLER. Endpoint is now READY.

290614:29:51.732 [pool-67-thread-7] INFO k.s.SharedServer - [SharedServer id=0] Starting SharedServer

290714:29:51.777 [pool-67-thread-7] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs7572554700115704093] Loading producer state till offset 0

290814:29:51.778 [pool-67-thread-7] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs7572554700115704093] Reloading from producer snapshot and rebuilding producer state from offset 0

290914:29:51.778 [pool-67-thread-7] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-logs7572554700115704093] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0

291014:29:51.797 [pool-67-thread-7] INFO k.r.KafkaMetadataLog$ - Initialized snapshots with IDs SortedSet() from /tmp/kafka-logs7572554700115704093/__cluster_metadata-0

291114:29:51.808 [raft-expiration-reaper] INFO o.a.k.r.TimingWheelExpirationService$ExpiredOperationReaper - [raft-expiration-reaper]: Starting

291214:29:51.821 [pool-67-thread-7] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Reading KRaft snapshot and log as part of the initialization

291314:29:51.822 [pool-67-thread-7] 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])})

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

291514:29:51.829 [pool-67-thread-7] 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=1660, highWatermark=Optional.empty) from null

291614:29:51.903 [pool-67-thread-7] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1660, highWatermark=Optional.empty) from null

291714:29:51.906 [pool-67-thread-7] 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=1791, highWatermark=Optional.empty) from UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1660, highWatermark=Optional.empty)

291814:29:51.907 [pool-67-thread-7] INFO o.a.k.r.QuorumState - [RaftManager id=0] Attempting durable transition to CandidateState(localId=0, localDirectoryId=wZSvsjOHZk681DfKN9_ltw, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1893) from ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1791, highWatermark=Optional.empty)

291914:29:51.913 [pool-67-thread-7] INFO o.a.k.r.QuorumState - [RaftManager id=0] Completed transition to CandidateState(localId=0, localDirectoryId=wZSvsjOHZk681DfKN9_ltw, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1893) from ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1791, highWatermark=Optional.empty)

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

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

292214:29:51.937 [kafka-0-raft-outbound-request-thread] INFO o.a.k.r.KafkaNetworkChannel$SendThread - [kafka-0-raft-outbound-request-thread]: Starting

292314:29:51.937 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClientDriver - [kafka-0-raft-io-thread]: Starting

292414:29:51.951 [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.

292514:29:51.952 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for controller quorum voters future

292614:29:51.952 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for controller quorum voters future

292714:29:51.956 [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)]

292814:29:51.962 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Registered the listener org.apache.kafka.image.loader.MetadataLoader@1133527393

292914:29:51.963 [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@1133527393 to 0 since there are no snapshots

293014:29:51.965 [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

293114:29:51.981 [pool-67-thread-7] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task writeNoOpRecord to run every 500 ms

293214:29:51.981 [pool-67-thread-7] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task maybeFenceStaleBroker to run every 1125 ms

293314:29:51.981 [pool-67-thread-7] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task electPreferred to run every 300000 ms

293414:29:51.981 [pool-67-thread-7] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task electUnclean to run every 300000 ms

293514:29:51.981 [pool-67-thread-7] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task expireDelegationTokens to run every 3600000 ms

293614:29:51.982 [pool-67-thread-7] INFO o.a.k.c.PeriodicTaskControlManager - [QuorumController id=0] Registering periodic task generatePeriodicPerformanceMessage to run every 60000 ms

293714:29:51.982 [pool-67-thread-7] INFO o.a.k.c.QuorumController - [QuorumController id=0] Creating new QuorumController with clusterId Rv5ipS8WQ9OWJ9EWetzHMA

293814:29:51.983 [kafka-0-raft-io-thread] INFO o.a.k.r.KafkaRaftClient - [RaftManager id=0] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@1046441939

293914:29:51.983 [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@1046441939 to 0 since there are no snapshots

294014:29:51.985 [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.

294114:29:51.989 [controller-0-ThrottledChannelReaper-Fetch] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Fetch]: Starting

294214:29:51.989 [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'.

294314:29:51.990 [controller-0-ThrottledChannelReaper-Produce] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Produce]: Starting

294414:29:51.990 [controller-0-ThrottledChannelReaper-Request] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-Request]: Starting

294514:29:51.992 [controller-0-ThrottledChannelReaper-ControllerMutation] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [controller-0-ThrottledChannelReaper-ControllerMutation]: Starting

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

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

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

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

295014:29:52.005 [ExpirationReaper-0-AlterAcls] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-AlterAcls]: Starting

295114:29:52.017 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for the controller metadata publishers to be installed

295214:29:52.017 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for the controller metadata publishers to be installed

295314:29:52.017 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] initializeNewPublishers: The loader is still catching up because we have not loaded a controller record as of offset 0 and high water mark is 1

295414:29:52.017 [pool-67-thread-7] INFO k.n.SocketServer - [SocketServer listenerType=CONTROLLER, nodeId=0] Enabling request processing.

295514:29:52.023 [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

295614:29:52.025 [pool-67-thread-7] INFO k.n.DataPlaneAcceptor - Awaiting socket connections on localhost:6002.

295714:29:52.026 [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

295814:29:52.026 [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

295914:29:52.026 [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

296014:29:52.034 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for all of the authorizer futures to be completed

296114:29:52.034 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for all of the authorizer futures to be completed

296214:29:52.034 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=tHYPO5N7Ql6gyQ8C-tlBnA] initialized channel manager.

296314:29:52.034 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Waiting for all of the SocketServer Acceptors to be started

296414:29:52.034 [pool-67-thread-7] INFO k.s.ControllerServer - [ControllerServer id=0] Finished waiting for all of the SocketServer Acceptors to be started

296514:29:52.034 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=tHYPO5N7Ql6gyQ8C-tlBnA] maybeSendControllerRegistration: cannot register yet because the metadata.version is not known yet.

296614:29:52.035 [controller-0-to-controller-registration-channel-manager] INFO k.s.NodeToControllerRequestThread - [controller-0-to-controller-registration-channel-manager]: Starting

296714:29:52.035 [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)

296814:29:52.038 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Transition from SHUTDOWN to STARTING

296914:29:52.038 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Starting broker

297014:29:52.040 [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].

297114:29:52.040 [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

297214:29:52.040 [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

297314:29:52.041 [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

297414:29:52.045 [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

297514:29:52.046 [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

297614:29:52.046 [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

297714:29:52.046 [broker-0-ThrottledChannelReaper-Fetch] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Fetch]: Starting

297814:29:52.047 [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

297914:29:52.048 [broker-0-ThrottledChannelReaper-Produce] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Produce]: Starting

298014:29:52.049 [broker-0-ThrottledChannelReaper-Request] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-Request]: Starting

298114:29:52.050 [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

298214:29:52.051 [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

298314:29:52.051 [broker-0-ThrottledChannelReaper-ControllerMutation] INFO k.s.ClientQuotaManager$ThrottledChannelReaper - [broker-0-ThrottledChannelReaper-ControllerMutation]: Starting

298414:29:52.057 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=tHYPO5N7Ql6gyQ8C-tlBnA] sendControllerRegistration: attempting to send ControllerRegistrationRequestData(controllerId=0, incarnationId=tHYPO5N7Ql6gyQ8C-tlBnA, 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)])

298514:29:52.072 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for controller quorum voters future

298614:29:52.072 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for controller quorum voters future

298714:29:52.075 [broker-0-to-controller-forwarding-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-forwarding-channel-manager]: Starting

298814:29:52.075 [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)

298914:29:52.082 [client-metrics-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [client-metrics-reaper]: Starting

299014:29:52.128 [pool-67-thread-7] INFO k.n.ConnectionQuotas - Updated connection-accept-rate max connection creation rate to 2147483647

299114:29:52.132 [pool-67-thread-7] INFO k.n.SocketServer - [SocketServer listenerType=BROKER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(BROKER)

299214:29:52.138 [broker-0-to-controller-alter-partition-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-alter-partition-channel-manager]: Starting

299314:29:52.139 [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)

299414:29:52.145 [broker-0-to-controller-directory-assignments-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-directory-assignments-channel-manager]: Starting

299514:29:52.150 [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)

299614:29:52.151 [quorum-controller-0-event-handler] INFO o.a.k.c.ClusterControlManager - [QuorumController id=0] Replayed RegisterControllerRecord containing ControllerRegistration(id=0, incarnationId=tHYPO5N7Ql6gyQ8C-tlBnA, 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}).

299714:29:52.162 [ExpirationReaper-0-Produce] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-Produce]: Starting

299814:29:52.163 [ExpirationReaper-0-Fetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-Fetch]: Starting

299914:29:52.164 [ExpirationReaper-0-DeleteRecords] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-DeleteRecords]: Starting

300014:29:52.165 [ExpirationReaper-0-RemoteFetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-RemoteFetch]: Starting

300114:29:52.166 [ExpirationReaper-0-RemoteListOffsets] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-RemoteListOffsets]: Starting

300214:29:52.167 [ExpirationReaper-0-ShareFetch] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-ShareFetch]: Starting

300314:29:52.171 [controller-0-to-controller-registration-channel-manager] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=tHYPO5N7Ql6gyQ8C-tlBnA] RegistrationResponseHandler: controller acknowledged ControllerRegistrationRequest.

300414:29:52.171 [controller-0-registration-manager-event-handler] INFO k.s.ControllerRegistrationManager - [ControllerRegistrationManager id=0 incarnation=tHYPO5N7Ql6gyQ8C-tlBnA] Our registration has been persisted to the metadata log.

300514:29:52.186 [share-coordinator-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [share-coordinator-reaper]: Starting

300614:29:52.203 [share-coordinator-event-processor-0] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [share-coordinator-event-processor-0]: Starting

300714:29:52.208 [persister-state-manager-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [persister-state-manager-reaper]: Starting

300814:29:52.209 [PersisterStateManager] INFO o.a.k.s.s.p.PersisterStateManager$SendThread - [PersisterStateManager]: Starting

300914:29:52.209 [group-coordinator-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [group-coordinator-reaper]: Starting

301014:29:52.217 [group-coordinator-event-processor-0] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-0]: Starting

301114:29:52.217 [group-coordinator-event-processor-1] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-1]: Starting

301214:29:52.218 [group-coordinator-event-processor-2] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-2]: Starting

301314:29:52.219 [group-coordinator-event-processor-3] INFO o.a.k.c.c.r.MultiThreadedEventProcessor$EventProcessorThread - [group-coordinator-event-processor-3]: Starting

301414:29:52.235 [pool-67-thread-7] INFO k.l.LogManager - Unable to read the broker epoch in /tmp/kafka-logs7572554700115704093.

301514:29:52.237 [broker-0-to-controller-heartbeat-channel-manager] INFO k.s.NodeToControllerRequestThread - [broker-0-to-controller-heartbeat-channel-manager]: Starting

301614:29:52.237 [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)

301714:29:52.239 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] Incarnation K-jRYEn6SwSTCNAF_kXSxg of broker 0 in cluster Rv5ipS8WQ9OWJ9EWetzHMA is now STARTING.

301814:29:52.244 [share-group-lock-timeout-reaper] INFO o.a.k.s.u.t.SystemTimerReaper$Reaper - [share-group-lock-timeout-reaper]: Starting

301914:29:52.247 [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 K-jRYEn6SwSTCNAF_kXSxg. Generated 0 record(s) to clean up previous incarnations. New broker epoch is 5.

302014:29:52.256 [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=K-jRYEn6SwSTCNAF_kXSxg, 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=[wZSvsjOHZk681DfKN9_ltw])

302114:29:52.259 [ExpirationReaper-0-AlterAcls] INFO o.a.k.s.p.DelayedOperationPurgatory$ExpiredOperationReaper - [ExpirationReaper-0-AlterAcls]: Starting

302214:29:52.275 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the broker metadata publishers to be installed

302314:29:52.278 [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 5

302414:29:52.278 [kafka-0-metadata-loader-event-handler] INFO o.a.k.i.l.MetadataLoader - [MetadataLoader id=0] InitializeNewPublishers: initializing BrokerMetadataPublisher with a snapshot at offset 5

302514:29:52.279 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] Successfully registered broker 0 with broker epoch 5

302614:29:52.279 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the broker metadata publishers to be installed

302714:29:52.279 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the controller to acknowledge that we are caught up

302814:29:52.281 [kafka-0-metadata-loader-event-handler] INFO k.s.m.BrokerMetadataPublisher - [BrokerMetadataPublisher id=0] Publishing initial metadata at offset OffsetAndEpoch[offset=5, epoch=1] with metadata.version Optional[4.1-IV1].

302914:29:52.282 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Loading logs from log dirs ArrayBuffer(/tmp/kafka-logs7572554700115704093)

303014:29:52.285 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - No logs found to be loaded in /tmp/kafka-logs7572554700115704093

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

303214:29:52.285 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the controller to acknowledge that we are caught up

303314:29:52.285 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the initial broker metadata update to be published

303414:29:52.291 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Loaded 0 logs in 7ms

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

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

303714:29:52.298 [broker-0-lifecycle-manager-event-handler] INFO k.s.BrokerLifecycleManager - [BrokerLifecycleManager id=0] The broker is in RECOVERY.

303814:29:52.299 [kafka-0-metadata-loader-event-handler] INFO o.a.k.s.i.l.LogCleaner - Starting the log cleaner

303914:29:52.304 [kafka-log-cleaner-thread-0] INFO o.a.k.s.i.l.LogCleaner$CleanerThread - [kafka-log-cleaner-thread-0]: Starting

304014:29:52.307 [AddPartitionsToTxnSenderThread-0] INFO o.a.k.s.t.AddPartitionsToTxnManager - [AddPartitionsToTxnSenderThread-0]: Starting

304114:29:52.307 [LogDirFailureHandler] INFO k.s.ReplicaManager$LogDirFailureHandler - [LogDirFailureHandler]: Starting

304214:29:52.310 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.g.GroupCoordinatorService - [GroupCoordinator id=0] Starting up.

304314:29:52.310 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.g.GroupCoordinatorService - [GroupCoordinator id=0] Startup complete.

304414:29:52.311 [kafka-0-metadata-loader-event-handler] INFO k.c.t.TransactionCoordinator - [TransactionCoordinator id=0] Starting up.

304514:29:52.312 [kafka-0-metadata-loader-event-handler] INFO k.c.t.TransactionCoordinator - [TransactionCoordinator id=0] Startup complete.

304614:29:52.312 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.s.ShareCoordinatorService - [ShareCoordinator id=0] Starting up.

304714:29:52.312 [TxnMarkerSenderThread-0] INFO k.c.t.TransactionMarkerChannelManager - [TxnMarkerSenderThread-0]: Starting

304814:29:52.312 [kafka-0-metadata-loader-event-handler] INFO o.a.k.c.s.ShareCoordinatorService - [ShareCoordinator id=0] Startup complete.

304914:29:52.317 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the initial broker metadata update to be published

305014:29:52.317 [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 5

305114:29:52.318 [pool-67-thread-7] INFO o.a.k.c.c.AbstractConfig - KafkaConfig values:

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

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

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

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

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

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

3058 authorizer.class.name =

3059 auto.create.topics.enable = true

3060 auto.leader.rebalance.enable = true

3061 background.threads = 10

3062 broker.heartbeat.interval.ms = 2000

3063 broker.id = 0

3064 broker.rack = null

3065 broker.session.timeout.ms = 9000

3066 client.quota.callback.class = null

3067 compression.gzip.level = -1

3068 compression.lz4.level = 9

3069 compression.type = producer

3070 compression.zstd.level = 3

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

3072 connections.max.idle.ms = 600000

3073 connections.max.reauth.ms = 0

3074 controlled.shutdown.enable = true

3075 controller.listener.names = CONTROLLER

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

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

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

3079 controller.quorum.bootstrap.servers = []

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

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

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

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

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

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

3086 controller.quota.window.num = 11

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

3088 controller.socket.timeout.ms = 30000

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

3090 default.replication.factor = 1

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

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

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

3094 delegation.token.secret.key = null

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

3096 delete.topic.enable = true

3097 early.start.listeners = null

3098 fetch.max.bytes = 57671680

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

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

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

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

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

3104 group.consumer.max.size = 2147483647

3105 group.consumer.migration.policy = bidirectional

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

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

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

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

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

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

3112 group.coordinator.threads = 4

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

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

3115 group.max.size = 2147483647

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

3117 group.share.assignors = [simple]

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

3119 group.share.enable = false

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

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

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

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

3124 group.share.max.share.sessions = 2000

3125 group.share.max.size = 200

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

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

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

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

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

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

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

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

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

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

3136 group.streams.max.size = 2147483647

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

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

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

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

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

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

3143 inter.broker.listener.name = BROKER

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

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

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

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

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

3149 kafka.metrics.reporters = []

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

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

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

3153 log.cleaner.backoff.ms = 15000

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

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

3156 log.cleaner.enable = true

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

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

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

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

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

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

3163 log.cleaner.threads = 1

3164 log.cleanup.policy = [delete]

3165 log.dir = /tmp/kafka-logs

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

3167 log.dirs = /tmp/kafka-logs7572554700115704093

3168 log.flush.interval.messages = 1

3169 log.flush.interval.ms = null

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

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

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

3173 log.index.interval.bytes = 4096

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

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

3176 log.local.retention.bytes = -2

3177 log.local.retention.ms = -2

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

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

3180 log.message.timestamp.type = CreateTime

3181 log.preallocate = false

3182 log.retention.bytes = -1

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

3184 log.retention.hours = 168

3185 log.retention.minutes = null

3186 log.retention.ms = null

3187 log.roll.hours = 168

3188 log.roll.jitter.hours = 0

3189 log.roll.jitter.ms = null

3190 log.roll.ms = null

3191 log.segment.bytes = 1073741824

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

3193 max.connection.creation.rate = 2147483647

3194 max.connections = 2147483647

3195 max.connections.per.ip = 2147483647

3196 max.connections.per.ip.overrides =

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

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

3199 message.max.bytes = 1048588

3200 metadata.log.dir = null

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

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

3203 metadata.log.segment.bytes = 1073741824

3204 metadata.log.segment.ms = 604800000

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

3206 metadata.max.retention.bytes = 104857600

3207 metadata.max.retention.ms = 604800000

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

3209 metrics.num.samples = 2

3210 metrics.recording.level = INFO

3211 metrics.sample.window.ms = 30000

3212 min.insync.replicas = 1

3213 node.id = 0

3214 num.io.threads = 8

3215 num.network.threads = 3

3216 num.partitions = 1

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

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

3219 num.replica.fetchers = 1

3220 offset.metadata.max.bytes = 4096

3221 offsets.commit.timeout.ms = 5000

3222 offsets.load.buffer.size = 5242880

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

3224 offsets.retention.minutes = 10080

3225 offsets.topic.compression.codec = 0

3226 offsets.topic.num.partitions = 1

3227 offsets.topic.replication.factor = 1

3228 offsets.topic.segment.bytes = 104857600

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

3230 process.roles = [broker, controller]

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

3232 producer.id.expiration.ms = 86400000

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

3234 queued.max.request.bytes = -1

3235 queued.max.requests = 500

3236 quota.window.num = 11

3237 quota.window.size.seconds = 1

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

3260 remote.log.reader.threads = 10

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

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

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

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

3265 replica.fetch.backoff.ms = 1000

3266 replica.fetch.max.bytes = 1048576

3267 replica.fetch.min.bytes = 1

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

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

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

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

3272 replica.selector.class = null

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

3274 replica.socket.timeout.ms = 30000

3275 replication.quota.window.num = 11

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

3277 request.timeout.ms = 30000

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

3279 sasl.enabled.mechanisms = [GSSAPI]

3280 sasl.jaas.config = null

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

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

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

3284 sasl.kerberos.service.name = null

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

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

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

3288 sasl.login.class = null

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

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

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

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

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

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

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

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

3297 sasl.mechanism.controller.protocol = GSSAPI

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

3299 sasl.oauthbearer.assertion.algorithm = RS256

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

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

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

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

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

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

3306 sasl.oauthbearer.assertion.file = null

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

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

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

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

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

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

3313 sasl.oauthbearer.expected.audience = null

3314 sasl.oauthbearer.expected.issuer = null

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

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

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

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

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

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

3321 sasl.oauthbearer.scope = null

3322 sasl.oauthbearer.scope.claim.name = scope

3323 sasl.oauthbearer.sub.claim.name = sub

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

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

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

3327 security.inter.broker.protocol = PLAINTEXT

3328 security.providers = null

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

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

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

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

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

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

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

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

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

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

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

3340 share.coordinator.threads = 1

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

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

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

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

3345 socket.listen.backlog.size = 50

3346 socket.receive.buffer.bytes = 102400

3347 socket.request.max.bytes = 104857600

3348 socket.send.buffer.bytes = 102400

3349 ssl.allow.dn.changes = false

3350 ssl.allow.san.changes = false

3351 ssl.cipher.suites = []

3352 ssl.client.auth = none

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

3354 ssl.endpoint.identification.algorithm = https

3355 ssl.engine.factory.class = null

3356 ssl.key.password = null

3357 ssl.keymanager.algorithm = SunX509

3358 ssl.keystore.certificate.chain = null

3359 ssl.keystore.key = null

3360 ssl.keystore.location = null

3361 ssl.keystore.password = null

3362 ssl.keystore.type = JKS

3363 ssl.principal.mapping.rules = DEFAULT

3364 ssl.protocol = TLSv1.3

3365 ssl.provider = null

3366 ssl.secure.random.implementation = null

3367 ssl.trustmanager.algorithm = PKIX

3368 ssl.truststore.certificates = null

3369 ssl.truststore.location = null

3370 ssl.truststore.password = null

3371 ssl.truststore.type = JKS

3372 telemetry.max.bytes = 1048576

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

3374 transaction.max.timeout.ms = 900000

3375 transaction.partition.verification.enable = true

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

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

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

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

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

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

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

3383 transactional.id.expiration.ms = 604800000

3384 unclean.leader.election.enable = false

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

3386 unstable.api.versions.enable = false

3387 unstable.feature.versions.enable = false

338914:29:52.322 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for the broker to be unfenced

339014:29:52.325 [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.

339114:29:52.330 [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=[])

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

339314:29:52.354 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for the broker to be unfenced

339414:29:52.355 [pool-67-thread-7] INFO o.a.k.s.n.EndpointReadyFutures - authorizerStart completed for endpoint BROKER. Endpoint is now READY.

339514:29:52.356 [pool-67-thread-7] INFO k.n.SocketServer - [SocketServer listenerType=BROKER, nodeId=0] Enabling request processing.

339614:29:52.356 [pool-67-thread-7] INFO k.n.DataPlaneAcceptor - Awaiting socket connections on localhost:6001.

339714:29:52.357 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for all of the authorizer futures to be completed

339814:29:52.357 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for all of the authorizer futures to be completed

339914:29:52.357 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Waiting for all of the SocketServer Acceptors to be started

340014:29:52.357 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Finished waiting for all of the SocketServer Acceptors to be started

340114:29:52.357 [pool-67-thread-7] INFO k.s.BrokerServer - [BrokerServer id=0] Transition from STARTING to STARTED

340214:29:52.380 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3403 acks = -1

3404 batch.size = 16384

3405 bootstrap.servers = [localhost:6001]

3406 buffer.memory = 33554432

3407 client.dns.lookup = use_all_dns_ips

3408 client.id = producer-1

3409 compression.gzip.level = -1

3410 compression.lz4.level = 9

3411 compression.type = none

3412 compression.zstd.level = 3

3413 connections.max.idle.ms = 540000

3414 delivery.timeout.ms = 120000

3415 enable.idempotence = true

3416 enable.metrics.push = true

3417 interceptor.classes = []

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

3419 linger.ms = 5

3420 max.block.ms = 10000

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

3422 max.request.size = 1048576

3423 metadata.max.age.ms = 300000

3424 metadata.max.idle.ms = 300000

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

3426 metadata.recovery.strategy = rebootstrap

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

3428 metrics.num.samples = 2

3429 metrics.recording.level = INFO

3430 metrics.sample.window.ms = 30000

3431 partitioner.adaptive.partitioning.enable = true

3432 partitioner.availability.timeout.ms = 0

3433 partitioner.class = null

3434 partitioner.ignore.keys = false

3435 receive.buffer.bytes = 32768

3436 reconnect.backoff.max.ms = 1000

3437 reconnect.backoff.ms = 50

3438 request.timeout.ms = 30000

3439 retries = 2147483647

3440 retry.backoff.max.ms = 1000

3441 retry.backoff.ms = 1000

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

3443 sasl.jaas.config = null

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

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

3446 sasl.kerberos.service.name = null

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

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

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

3450 sasl.login.class = null

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

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

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

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

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

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

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

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

3459 sasl.mechanism = GSSAPI

3460 sasl.oauthbearer.assertion.algorithm = RS256

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

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

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

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

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

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

3467 sasl.oauthbearer.assertion.file = null

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

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

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

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

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

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

3474 sasl.oauthbearer.expected.audience = null

3475 sasl.oauthbearer.expected.issuer = null

3476 sasl.oauthbearer.header.urlencode = false

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

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

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

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

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

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

3483 sasl.oauthbearer.scope = null

3484 sasl.oauthbearer.scope.claim.name = scope

3485 sasl.oauthbearer.sub.claim.name = sub

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

3487 security.protocol = PLAINTEXT

3488 security.providers = null

3489 send.buffer.bytes = 131072

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

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

3492 ssl.cipher.suites = null

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

3494 ssl.endpoint.identification.algorithm = https

3495 ssl.engine.factory.class = null

3496 ssl.key.password = null

3497 ssl.keymanager.algorithm = SunX509

3498 ssl.keystore.certificate.chain = null

3499 ssl.keystore.key = null

3500 ssl.keystore.location = null

3501 ssl.keystore.password = null

3502 ssl.keystore.type = JKS

3503 ssl.protocol = TLSv1.3

3504 ssl.provider = null

3505 ssl.secure.random.implementation = null

3506 ssl.trustmanager.algorithm = PKIX

3507 ssl.truststore.certificates = null

3508 ssl.truststore.location = null

3509 ssl.truststore.password = null

3510 ssl.truststore.type = JKS

3511 transaction.timeout.ms = 60000

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

3513 transactional.id = null

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

351614:29:52.404 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

351714:29:52.412 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-1] Instantiated an idempotent producer.

351814:29:52.427 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

351914:29:52.427 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

352014:29:52.427 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1764854992427

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

352214:29:52.453 [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}

352314:29:52.454 [kafka-producer-network-thread | producer-1] INFO o.a.k.c.Metadata - [Producer clientId=producer-1] Cluster ID: Rv5ipS8WQ9OWJ9EWetzHMA

352414:29:52.464 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] CreateTopics result(s): CreatableTopic(name='t1', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS

352514:29:52.465 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed TopicRecord for topic t1 with topic ID WhJh5sHeTC-ZloPVATgk-g.

352614:29:52.468 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed PartitionRecord for new partition t1-0 with topic ID WhJh5sHeTC-ZloPVATgk-g and PartitionRegistration(replicas=[0], directories=[wZSvsjOHZk681DfKN9_ltw], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).

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

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

352914:29:52.497 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Creating new partition t1-0 with topic id WhJh5sHeTC-ZloPVATgk-g.

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

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

353214:29:52.512 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Created log for partition t1-0 in /tmp/kafka-logs7572554700115704093/t1-0 with properties {}

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

353414:29:52.514 [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

353514:29:52.519 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Leader t1-0 with topic id Some(WhJh5sHeTC-ZloPVATgk-g) 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.

353614:29:53.461 [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

353714:29:53.495 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

353814:29:53.502 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

353914:29:53.502 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

354014:29:53.502 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

354114:29:53.502 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

354214:29:53.503 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-1 unregistered

354314:29:53.504 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3544 acks = -1

3545 batch.size = 16384

3546 bootstrap.servers = [localhost:6001]

3547 buffer.memory = 33554432

3548 client.dns.lookup = use_all_dns_ips

3549 client.id = producer-2

3550 compression.gzip.level = -1

3551 compression.lz4.level = 9

3552 compression.type = none

3553 compression.zstd.level = 3

3554 connections.max.idle.ms = 540000

3555 delivery.timeout.ms = 120000

3556 enable.idempotence = true

3557 enable.metrics.push = true

3558 interceptor.classes = []

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

3560 linger.ms = 5

3561 max.block.ms = 10000

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

3563 max.request.size = 1048576

3564 metadata.max.age.ms = 300000

3565 metadata.max.idle.ms = 300000

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

3567 metadata.recovery.strategy = rebootstrap

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

3569 metrics.num.samples = 2

3570 metrics.recording.level = INFO

3571 metrics.sample.window.ms = 30000

3572 partitioner.adaptive.partitioning.enable = true

3573 partitioner.availability.timeout.ms = 0

3574 partitioner.class = null

3575 partitioner.ignore.keys = false

3576 receive.buffer.bytes = 32768

3577 reconnect.backoff.max.ms = 1000

3578 reconnect.backoff.ms = 50

3579 request.timeout.ms = 30000

3580 retries = 2147483647

3581 retry.backoff.max.ms = 1000

3582 retry.backoff.ms = 1000

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

3584 sasl.jaas.config = null

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

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

3587 sasl.kerberos.service.name = null

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

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

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

3591 sasl.login.class = null

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

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

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

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

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

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

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

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

3600 sasl.mechanism = GSSAPI

3601 sasl.oauthbearer.assertion.algorithm = RS256

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

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

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

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

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

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

3608 sasl.oauthbearer.assertion.file = null

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

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

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

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

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

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

3615 sasl.oauthbearer.expected.audience = null

3616 sasl.oauthbearer.expected.issuer = null

3617 sasl.oauthbearer.header.urlencode = false

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

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

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

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

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

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

3624 sasl.oauthbearer.scope = null

3625 sasl.oauthbearer.scope.claim.name = scope

3626 sasl.oauthbearer.sub.claim.name = sub

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

3628 security.protocol = PLAINTEXT

3629 security.providers = null

3630 send.buffer.bytes = 131072

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

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

3633 ssl.cipher.suites = null

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

3635 ssl.endpoint.identification.algorithm = https

3636 ssl.engine.factory.class = null

3637 ssl.key.password = null

3638 ssl.keymanager.algorithm = SunX509

3639 ssl.keystore.certificate.chain = null

3640 ssl.keystore.key = null

3641 ssl.keystore.location = null

3642 ssl.keystore.password = null

3643 ssl.keystore.type = JKS

3644 ssl.protocol = TLSv1.3

3645 ssl.provider = null

3646 ssl.secure.random.implementation = null

3647 ssl.trustmanager.algorithm = PKIX

3648 ssl.truststore.certificates = null

3649 ssl.truststore.location = null

3650 ssl.truststore.password = null

3651 ssl.truststore.type = JKS

3652 transaction.timeout.ms = 60000

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

3654 transactional.id = null

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

365714:29:53.505 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

365814:29:53.505 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-2] Instantiated an idempotent producer.

365914:29:53.510 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

366014:29:53.510 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

366114:29:53.510 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1764854993510

366214:29:53.516 [kafka-producer-network-thread | producer-2] INFO o.a.k.c.Metadata - [Producer clientId=producer-2] Cluster ID: Rv5ipS8WQ9OWJ9EWetzHMA

366314:29:53.517 [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

366414:29:53.529 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

366514:29:53.533 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

366614:29:53.533 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

366714:29:53.533 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

366814:29:53.533 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

366914:29:53.533 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-2 unregistered

367014:29:53.534 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3671 acks = -1

3672 batch.size = 16384

3673 bootstrap.servers = [localhost:6001]

3674 buffer.memory = 33554432

3675 client.dns.lookup = use_all_dns_ips

3676 client.id = producer-3

3677 compression.gzip.level = -1

3678 compression.lz4.level = 9

3679 compression.type = none

3680 compression.zstd.level = 3

3681 connections.max.idle.ms = 540000

3682 delivery.timeout.ms = 120000

3683 enable.idempotence = true

3684 enable.metrics.push = true

3685 interceptor.classes = []

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

3687 linger.ms = 5

3688 max.block.ms = 10000

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

3690 max.request.size = 1048576

3691 metadata.max.age.ms = 300000

3692 metadata.max.idle.ms = 300000

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

3694 metadata.recovery.strategy = rebootstrap

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

3696 metrics.num.samples = 2

3697 metrics.recording.level = INFO

3698 metrics.sample.window.ms = 30000

3699 partitioner.adaptive.partitioning.enable = true

3700 partitioner.availability.timeout.ms = 0

3701 partitioner.class = null

3702 partitioner.ignore.keys = false

3703 receive.buffer.bytes = 32768

3704 reconnect.backoff.max.ms = 1000

3705 reconnect.backoff.ms = 50

3706 request.timeout.ms = 30000

3707 retries = 2147483647

3708 retry.backoff.max.ms = 1000

3709 retry.backoff.ms = 1000

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

3711 sasl.jaas.config = null

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

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

3714 sasl.kerberos.service.name = null

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

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

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

3718 sasl.login.class = null

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

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

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

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

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

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

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

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

3727 sasl.mechanism = GSSAPI

3728 sasl.oauthbearer.assertion.algorithm = RS256

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

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

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

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

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

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

3735 sasl.oauthbearer.assertion.file = null

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

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

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

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

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

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

3742 sasl.oauthbearer.expected.audience = null

3743 sasl.oauthbearer.expected.issuer = null

3744 sasl.oauthbearer.header.urlencode = false

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

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

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

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

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

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

3751 sasl.oauthbearer.scope = null

3752 sasl.oauthbearer.scope.claim.name = scope

3753 sasl.oauthbearer.sub.claim.name = sub

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

3755 security.protocol = PLAINTEXT

3756 security.providers = null

3757 send.buffer.bytes = 131072

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

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

3760 ssl.cipher.suites = null

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

3762 ssl.endpoint.identification.algorithm = https

3763 ssl.engine.factory.class = null

3764 ssl.key.password = null

3765 ssl.keymanager.algorithm = SunX509

3766 ssl.keystore.certificate.chain = null

3767 ssl.keystore.key = null

3768 ssl.keystore.location = null

3769 ssl.keystore.password = null

3770 ssl.keystore.type = JKS

3771 ssl.protocol = TLSv1.3

3772 ssl.provider = null

3773 ssl.secure.random.implementation = null

3774 ssl.trustmanager.algorithm = PKIX

3775 ssl.truststore.certificates = null

3776 ssl.truststore.location = null

3777 ssl.truststore.password = null

3778 ssl.truststore.type = JKS

3779 transaction.timeout.ms = 60000

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

3781 transactional.id = null

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

378414:29:53.534 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

378514:29:53.535 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-3] Instantiated an idempotent producer.

378614:29:53.540 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

378714:29:53.541 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

378814:29:53.541 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1764854993540

378914:29:53.549 [kafka-producer-network-thread | producer-3] INFO o.a.k.c.Metadata - [Producer clientId=producer-3] Cluster ID: Rv5ipS8WQ9OWJ9EWetzHMA

379014:29:53.550 [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

379114:29:53.562 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.p.KafkaProducer - [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

379214:29:53.567 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics scheduler closed

379314:29:53.567 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter

379414:29:53.567 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter

379514:29:53.567 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.m.Metrics - Metrics reporters closed

379614:29:53.567 [pool-67-thread-7-ScalaTest-running-KafkaTest] INFO o.a.k.c.u.AppInfoParser - App info kafka.producer for producer-3 unregistered

379714:29:53.586 [virtual-608] INFO o.a.k.c.c.AbstractConfig - ConsumerConfig values:

3798 allow.auto.create.topics = true

3799 auto.commit.interval.ms = 5000

3800 auto.offset.reset = earliest

3801 bootstrap.servers = [localhost:6001]

3802 check.crcs = true

3803 client.dns.lookup = use_all_dns_ips

3804 client.id = consumer-g1-1

3805 client.rack =

3806 connections.max.idle.ms = 540000

3807 default.api.timeout.ms = 60000

3808 enable.auto.commit = false

3809 enable.metrics.push = true

3810 exclude.internal.topics = true

3811 fetch.max.bytes = 52428800

3812 fetch.max.wait.ms = 500

3813 fetch.min.bytes = 1

3814 group.id = g1

3815 group.instance.id = null

3816 group.protocol = classic

3817 group.remote.assignor = null

3818 heartbeat.interval.ms = 3000

3819 interceptor.classes = []

3820 internal.leave.group.on.close = true

3821 internal.throw.on.fetch.stable.offset.unsupported = false

3822 isolation.level = read_uncommitted

3823 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

3824 max.partition.fetch.bytes = 1048576

3825 max.poll.interval.ms = 300000

3826 max.poll.records = 500

3827 metadata.max.age.ms = 300000

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

3829 metadata.recovery.strategy = rebootstrap

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

3831 metrics.num.samples = 2

3832 metrics.recording.level = INFO

3833 metrics.sample.window.ms = 30000

3834 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]

3835 receive.buffer.bytes = 65536

3836 reconnect.backoff.max.ms = 1000

3837 reconnect.backoff.ms = 50

3838 request.timeout.ms = 30000

3839 retry.backoff.max.ms = 1000

3840 retry.backoff.ms = 100

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

3842 sasl.jaas.config = null

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

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

3845 sasl.kerberos.service.name = null

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

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

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

3849 sasl.login.class = null

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

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

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

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

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

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

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

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

3858 sasl.mechanism = GSSAPI

3859 sasl.oauthbearer.assertion.algorithm = RS256

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

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

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

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

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

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

3866 sasl.oauthbearer.assertion.file = null

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

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

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

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

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

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

3873 sasl.oauthbearer.expected.audience = null

3874 sasl.oauthbearer.expected.issuer = null

3875 sasl.oauthbearer.header.urlencode = false

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

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

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

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

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

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

3882 sasl.oauthbearer.scope = null

3883 sasl.oauthbearer.scope.claim.name = scope

3884 sasl.oauthbearer.sub.claim.name = sub

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

3886 security.protocol = PLAINTEXT

3887 security.providers = null

3888 send.buffer.bytes = 131072

3889 session.timeout.ms = 45000

3890 share.acknowledgement.mode = implicit

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

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

3893 ssl.cipher.suites = null

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

3895 ssl.endpoint.identification.algorithm = https

3896 ssl.engine.factory.class = null

3897 ssl.key.password = null

3898 ssl.keymanager.algorithm = SunX509

3899 ssl.keystore.certificate.chain = null

3900 ssl.keystore.key = null

3901 ssl.keystore.location = null

3902 ssl.keystore.password = null

3903 ssl.keystore.type = JKS

3904 ssl.protocol = TLSv1.3

3905 ssl.provider = null

3906 ssl.secure.random.implementation = null

3907 ssl.trustmanager.algorithm = PKIX

3908 ssl.truststore.certificates = null

3909 ssl.truststore.location = null

3910 ssl.truststore.password = null

3911 ssl.truststore.type = JKS

3912 value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

391414:29:53.595 [virtual-608] INFO o.a.k.c.t.i.KafkaMetricsCollector - initializing Kafka metrics collector

391514:29:53.638 [virtual-608] INFO o.a.k.c.u.AppInfoParser - Kafka version: 4.1.1

391614:29:53.638 [virtual-608] INFO o.a.k.c.u.AppInfoParser - Kafka commitId: be816b82d25370ce

391714:29:53.638 [virtual-608] INFO o.a.k.c.u.AppInfoParser - Kafka startTimeMs: 1764854993638

391814:29:53.663 [virtual-615] INFO o.a.k.c.c.i.ClassicKafkaConsumer - [Consumer clientId=consumer-g1-1, groupId=g1] Subscribed to topic(s): t1

391914:29:53.671 [virtual-615] INFO o.a.k.c.Metadata - [Consumer clientId=consumer-g1-1, groupId=g1] Cluster ID: Rv5ipS8WQ9OWJ9EWetzHMA

392014:29:53.673 [data-plane-kafka-request-handler-5] INFO k.s.DefaultAutoTopicCreationManager - Sent auto-creation request for Set(__consumer_offsets) to the active controller.

392114:29:53.678 [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

392214:29:53.679 [quorum-controller-0-event-handler] INFO o.a.k.c.ReplicationControlManager - [QuorumController id=0] Replayed TopicRecord for topic __consumer_offsets with topic ID nCn9WLKxSD2Uls0Rj9SfFw.

392314:29:53.680 [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

392414:29:53.680 [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

392514:29:53.680 [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

392614:29:53.680 [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 nCn9WLKxSD2Uls0Rj9SfFw and PartitionRegistration(replicas=[0], directories=[wZSvsjOHZk681DfKN9_ltw], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).

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

392814:29:53.708 [kafka-0-metadata-loader-event-handler] INFO k.s.ReplicaFetcherManager - [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(__consumer_offsets-0)

392914:29:53.708 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Creating new partition __consumer_offsets-0 with topic id nCn9WLKxSD2Uls0Rj9SfFw.

393014:29:53.711 [kafka-0-metadata-loader-event-handler] INFO o.a.k.s.i.l.UnifiedLog - [LogLoader partition=__consumer_offsets-0, dir=/tmp/kafka-logs7572554700115704093] Loading producer state till offset 0

393114:29:53.711 [kafka-0-metadata-loader-event-handler] INFO k.l.LogManager - Created log for partition __consumer_offsets-0 in /tmp/kafka-logs7572554700115704093/__consumer_offsets-0 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}

393214:29:53.711 [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

393314:29:53.711 [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

393414:29:53.712 [kafka-0-metadata-loader-event-handler] INFO s.c.logger - [Broker id=0] Leader __consumer_offsets-0 with topic id Some(nCn9WLKxSD2Uls0Rj9SfFw) 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.

393514:29:53.714 [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

393614:29:53.721 [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

393714:29:53.735 [group-coordinator-event-processor-1] INFO o.a.k.c.c.r.CoordinatorRuntime - [GroupCoordinator id=0] Finished loading of metadata from __consumer_offsets-0 with epoch 0 in 1ms where 1ms was spent in the scheduler. Loaded 0 records which total to 0 bytes.

393814:29:53.769 [virtual-615] 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)

393914:29:53.771 [virtual-615] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] (Re-)joining group

394014:29:53.781 [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-a43d3b6b-e9db-45dc-8c9d-29ec135104a1 and requesting the member to rejoin with this id.

394114:29:53.783 [virtual-615] 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-a43d3b6b-e9db-45dc-8c9d-29ec135104a1

394214:29:53.784 [virtual-615] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] (Re-)joining group

394314:29:53.788 [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-a43d3b6b-e9db-45dc-8c9d-29ec135104a1 joins group g1 in Empty state. Adding to the group now.

394414:29:53.789 [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-a43d3b6b-e9db-45dc-8c9d-29ec135104a1 with group instance id null; client reason: need to re-join with the given member-id: consumer-g1-1-a43d3b6b-e9db-45dc-8c9d-29ec135104a1).

394514:29:56.791 [group-coordinator-event-processor-2] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Stabilized group g1 generation 1 with 1 members.

394614:29:56.794 [virtual-615] 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-a43d3b6b-e9db-45dc-8c9d-29ec135104a1', protocol='range'}

394714:29:56.800 [virtual-615] 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-a43d3b6b-e9db-45dc-8c9d-29ec135104a1=Assignment(partitions=[t1-0])}

394814:29:56.804 [group-coordinator-event-processor-0] INFO o.a.k.c.g.GroupMetadataManager - [GroupCoordinator id=0 topic=__consumer_offsets partition=0] Assignment received from leader consumer-g1-1-a43d3b6b-e9db-45dc-8c9d-29ec135104a1 for group g1 for generation 1. The group has 1 members, 0 of which are static.

394914:29:56.812 [virtual-615] 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-a43d3b6b-e9db-45dc-8c9d-29ec135104a1', protocol='range'}

395014:29:56.812 [virtual-615] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Notifying assignor about the new Assignment(partitions=[t1-0])

395114:29:56.814 [virtual-615] INFO o.a.k.c.c.i.ConsumerRebalanceListenerInvoker - [Consumer clientId=consumer-g1-1, groupId=g1] Adding newly assigned partitions: [t1-0]

395214:29:56.823 [virtual-615] INFO o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=consumer-g1-1, groupId=g1] Found no committed offset for partition t1-0

395314:29:56.835 [virtual-615] 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}}.

395414:29:57.122 [virtual-608] INFO o.a.k.c.c.AbstractConfig - ProducerConfig values:

3955 acks = -1

3956 batch.size = 16384

3957 bootstrap.servers = [localhost:6001]

3958 buffer.memory = 33554432

3959 client.dns.lookup = use_all_dns_ips

3960 client.id = producer-4

3961 compression.gzip.level = -1

3962 compression.lz4.level = 9

3963 compression.type = none

3964 compression.zstd.level = 3

3965 connections.max.idle.ms = 540000

3966 delivery.timeout.ms = 120000

3967 enable.idempotence = true

3968 enable.metrics.push = true

3969 interceptor.classes = []

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

3971 linger.ms = 5

3972 max.block.ms = 10000

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

3974 max.request.size = 1048576

3975 metadata.max.age.ms = 300000

3976 metadata.max.idle.ms = 300000

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

3978 metadata.recovery.strategy = rebootstrap

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

3980 metrics.num.samples = 2

3981 metrics.recording.level = INFO

3982 metrics.sample.window.ms = 30000

3983 partitioner.adaptive.partitioning.enable = true

3984 partitioner.availability.timeout.ms = 0

3985 partitioner.class = null

3986 partitioner.ignore.keys = false

3987 receive.buffer.bytes = 32768

3988 reconnect.backoff.max.ms = 1000

3989 reconnect.backoff.ms = 50

3990 request.timeout.ms = 30000

3991 retries = 2147483647