Issues

• TcpConnectionSpec incoming-data test intermittently times out waiting for Tcp.Received

  apache/pekko#3626 · Filter by author He-Pin opened on Oct 13, 2026

• dispatcher: a rejected execution permanently strands a non-empty mailbox, and the rejection-reporting path recurses into StackOverflowError

  bug
  apache/pekko#3613 · Filter by author He-Pin opened on Oct 10, 2026
  2

  

• stream: synchronous source queue with overflow strategies (ConcurrentLinkedQueue-backed dropHead)

  apache/pekko#3612 · Filter by author He-Pin opened on Oct 10, 2026
  

• MergeLatest does not backpressure upstreams and buffers without bound

  apache/pekko#3592 · Filter by author pjfanning opened on Oct 8, 2026 · 2.0.0-M5
  1

• support the Secret Service API

  apache/pekko#3401 · Filter by author pjfanning opened on Jul 30, 2026
  1

• LeveldbJournalNativeSpec fails on macOS ARM64 because leveldbjni-all lacks an arm64 library

  apache/pekko#3327 · Filter by author He-Pin opened on Jul 11, 2026

• Address already in use

  apache/pekko#3326 · Filter by author He-Pin opened on Jul 11, 2026

• Flaky test: RemotingSpec "should resume the outbound reader when passive read handoff fails" on Scala 3

  apache/pekko#3308 · Filter by author He-Pin opened on Jul 9, 2026

• Explore a new design of dispatcher？

  apache/pekko#3254 · Filter by author He-Pin opened on Jun 28, 2026

• Classic Transport: Add Parallel Serialization/Deserialization via Netty Pipeline Executor

  enhancement
  apache/pekko#3204 · Filter by author He-Pin opened on Jun 27, 2026
  6

• Add health check support for Persistence journal and snapshot store

  apache/pekko#3128 · Filter by author He-Pin opened on Jun 22, 2026

• Add OpenTelemetry end-to-end trace context propagation for Pekko Streams

  akkadotnetenhancementt:stream
  apache/pekko#3107 · Filter by author He-Pin opened on Jun 20, 2026
  5

• GroupBy should support infinite substreams with maxSubstreams=-1

  akkadotnetenhancementt:stream
  apache/pekko#3102 · Filter by author He-Pin opened on Jun 20, 2026
  1

• AbstractRemoteSendConsistencySpec actorSelection preserving order test now flaky

  flaky
  apache/pekko#3089 · Filter by author pjfanning opened on Jun 19, 2026
  5

• Unix-Domain Socket Channels support in pekko ?

  apache/pekko#3043 · Filter by author He-Pin opened on Jun 4, 2026

• drop leveldb

  apache/pekko#2926 · Filter by author He-Pin opened on Apr 27, 2026 · 2.0.0-maybes
  1

• Rewritten more to graphstage

  apache/pekko#2860 · Filter by author He-Pin opened on Apr 14, 2026
  9

• More Scala code

  apache/pekko#2830 · Filter by author He-Pin opened on Apr 2, 2026
  1

• Add zstd compression/decompression IO Stream

  apache/pekko#2404 · Filter by author mdedetrich opened on Oct 27, 2025 · 2.0.0-maybes
  8

  

• Add Sink.watchTermination operator

  t:stream
  apache/pekko#2377 · Filter by author He-Pin opened on Oct 25, 2025 · 2.0.0-maybes

• Revisit indexOfSlice performance improvements

  apache/pekko#2321 · Filter by author pjfanning opened on Oct 18, 2025 · 2.0.0-maybes
  1

• Should the Decider of stream be a Function2?

  t:stream
  apache/pekko#2288 · Filter by author He-Pin opened on Sep 30, 2025 · 2.0.0-maybes
  2

• Cross build sbt plugin to sbt 2.x

  build
  apache/pekko#2210 · Filter by author He-Pin opened on Sep 13, 2025
  5

• Rewrite org.apache.pekko.japi.function.* in Java?

  apache/pekko#2185 · Filter by author He-Pin opened on Sep 9, 2025
  8

• Add Flow#collectNonNull operator

  t:stream
  apache/pekko#2178 · Filter by author He-Pin opened on Sep 7, 2025 · 2.0.0-maybes
  30