All pull requests

Pull requests

• Preserve shard regions after coordinator lease loss #3697

  #3709·He-Pin opened Oct 24, 2026Member·

  ·

  · 2.1.0
  1

  6

• fix: back off TCP accepts after listener errors (#3692)

  #3708·He-Pin opened Oct 24, 2026Member·

  ·

  · 2.1.0
  1

  2

• fix: stop and clean up failed throttled associations (#3688)

  #3706·He-Pin opened Oct 24, 2026Member·

  ·

  · 2.1.0
  1

  5

• fix: recognize replication senders independently of quorum membership

  #3704·He-Pin opened Oct 24, 2026Member·

  ·

  · 2.1.0
  1

  8

• fix: account for pending handshake messages when streams stop (#3690)

  #3702·He-Pin opened Oct 24, 2026Member·

  ·

  · 2.1.0
  1

  8

• Complete shard handoff during initialization

  #3701·He-Pin opened Oct 24, 2026Member·

  ·

  · 2.1.0
  1

  6

• Release and report singleton leases on manager termination #3685

  #3699·He-Pin opened Oct 24, 2026Member·

  ·

  · 2.1.0
  1

  5

• docs: update 2.0.0 release notes and migration guide for latest merges

  #3675·pjfanning opened Oct 23, 2026Member·

  ·

  · 2.0.0-M5

• [EXPERIMENT] build with Scala 3.10.0 as next Scala 3 version

  #3619·pjfanning opened Oct 12, 2026Member·

  ·
  6

• feat: add Sink.watchTermination operator

  #3409·He-Pin opened Aug 4, 2026Member·

  ·

  · 2.1.0
  1

  4

• refactor: replace sort-imports plugin with scalafix OrganizeImports

  #3342·He-Pin opened Jul 13, 2026Member·

  ·
  7

• Add Stream type-pollution benchmark and guidance

  #3333·He-Pin opened Jul 11, 2026Member·

  ·

• refactor: remove deprecated DurableStateUpdateStore.deleteObject(persistenceId) (since Akka 2.6.20)

  #3290·He-Pin opened Jul 4, 2026Member·

  ·
  1

• chore: Migrate build from sbt 1.x to sbt 2.x

  #3052·He-Pin opened Jun 6, 2026Member·12 of 23 tasks·

  ·

• feat: Add BidirectionalGracefulShutdown CancellationStrategy

  #3024·He-Pin opened May 31, 2026Member·

  ·
  1

  2

• Avoid substream subscription timeout for empty prefixAndTail tails

  #2991·He-Pin opened May 25, 2026Member·

  ·

• docs: link published management docs

  #2955·He-Pin opened May 9, 2026Member·

  ·
  4

• stream: optimize gather hot path and polish for upstream

  #2848·He-Pin opened Apr 6, 2026Member·4 tasks done·

  ·

  · 2.x-maybes
  8

• Add defensive sequence number validation in replicated event persistence

  #2815·He-Pin opened Mar 28, 2026Member·

  ·

• Add opt-in stream error log throttling

  #2814·He-Pin opened Mar 28, 2026Member·

  ·

• DRAFT: Split ActorSystem creation into javadsl and scaladsl

  #2479·mdedetrich opened Nov 12, 2025Contributor·

  ·

  · 2.x-maybes
  35

• move Java 9 Flow support into main Source and Sink classes

  #2460·pjfanning opened Nov 8, 2025Member·

  ·
  11

• Add zstd compression and decompression for pekko streams

  #2409·mdedetrich opened Oct 28, 2025Contributor·

  ·

  · 2.x-maybes
  1

  114

• Replace Lightbend Config with sconfig

  #2187·mdedetrich opened Sep 10, 2025Contributor·

  ·

  · 2.x-maybes
  11

• feat: Add asJavaStream to Sink

  t:stream
  #2156·He-Pin opened Sep 6, 2025Member·

  ·

  · 2.x-maybes
  34