pekko icon indicating copy to clipboard operation
pekko copied to clipboard

Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala

Results 243 pekko issues
Sort by recently updated
recently updated
newest added

https://github.com/apache/incubator-pekko-platform-guide This guide is referenced quite a bit from the main docs associated with this repo. Edit: the doc refs from this repo have been temporarily removed which means that...

good first issue
help wanted

Motivation: With the current ` type Decider = Function[Throwable, Directive]` , we can not know the current element that causes the exception, I think it would be better to be...

t:stream

Seems the scala-stew action can only update dependencies against main, not other branches, eg 1.3.x

Motivation: refs: https://github.com/apache/pekko/issues/2268 Try to fix this by set reuse address to true.

flaky

Even I'm not checking it for now, but I think we should find all `Java api` and recheck it for 2.0.0

``` [WARN] [09/25/2025 04:10:12.973] [pool-1-thread-1-ScalaTest-running-RemotingSpec] [org.apache.pekko.remote.RemoteActorRefProvider] Using the 'remote' ActorRefProvider directly, which is a low-level layer. For most use cases, the 'cluster' abstraction on top of remoting is more suitable...

flaky

The Pekko ByteString uses a byte array as backing. Netty has support for DirectByteBufs (ByteBufs that use an off-heap ByteBuffer - aka Direct ByteBuffer). pekko-actor already has DirectByteBufferPool - so...

```scala [09-22 05:32:10.899] [info] - must be established after initial lazy restart *** FAILED *** (24 seconds, 41 milliseconds) [09-22 05:32:10.899] [info] java.lang.AssertionError: assertion failed: timeout (20 seconds) during expectMsg...

2.13.17 not yet released but nightlies are available to test with. pekko-actor compile fails with ``` [info] compiling 196 Scala sources and 27 Java sources to /home/code/pekko/actor/target/scala-2.13/classes ... [error] /home/code/pekko/actor/src/main/scala-2.13/org/apache/pekko/util/ByteString.scala:924:29:...

* My understanding is that reactivestreams dependency is only really needed to support Java 8 users * Java 9+ users can use https://docs.oracle.com/javase/9/docs/api/java/util/concurrent/Flow.html and related classes * In theory, users...