The GitHub Actions job "Nightly Build and Test" on
pekko-connectors-kafka.git/main has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
a26e13ce2e5889dc27457b1d81292ea9c226f338 / scala-steward-asf[bot]
<147768647+scala-steward-asf[bot]@users.noreply.g
The GitHub Actions job "Nightly Builds" on pekko.git/main has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
197fb6e60e6df89abe46caf0750b7cf95052524c / He-Pin(kerr)
fix: Change aggregateWithBoundary operator in javadsl to use Optional. (#1876)
Repor
The GitHub Actions job "Nightly Builds (1.1)" on pekko.git/main has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
197fb6e60e6df89abe46caf0750b7cf95052524c / He-Pin(kerr)
fix: Change aggregateWithBoundary operator in javadsl to use Optional. (#1876)
The GitHub Actions job "Build and test Pekko with Scala 3" on pekko.git/main
has failed.
Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run:
197fb6e60e6df89abe46caf0750b7cf95052524c / He-Pin(kerr)
fix: Change aggregateWithBoundary operator in javadsl to use Opti
The GitHub Actions job "Nightly Aeron Tests" on pekko.git/main has succeeded.
Run started by GitHub user jrudolph (triggered by jrudolph).
Head commit for run:
197fb6e60e6df89abe46caf0750b7cf95052524c / He-Pin(kerr)
fix: Change aggregateWithBoundary operator in javadsl to use Optional. (#1876)
andreaslochbihler-da commented on code in PR #1841:
URL: https://github.com/apache/pekko/pull/1841#discussion_r2116371619
##
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Hub.scala:
##
@@ -475,13 +475,18 @@ object BroadcastHub {
/**
* INTERNAL API
+ *
+ * @param re
andreaslochbihler-da commented on code in PR #1841:
URL: https://github.com/apache/pekko/pull/1841#discussion_r2116370481
##
stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/HubSpec.scala:
##
@@ -561,6 +561,49 @@ class HubSpec extends StreamSpec {
out.expectCo
pjfanning commented on code in PR #1841:
URL: https://github.com/apache/pekko/pull/1841#discussion_r2116210537
##
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Hub.scala:
##
@@ -475,13 +475,18 @@ object BroadcastHub {
/**
* INTERNAL API
+ *
+ * @param registrationP
NavidJalali commented on code in PR #684:
URL: https://github.com/apache/pekko-http/pull/684#discussion_r2116031855
##
http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/headers/headers.scala:
##
@@ -1226,3 +1225,70 @@ final case class `X-Real-Ip`(address: RemoteAddre
jrudolph commented on PR #684:
URL: https://github.com/apache/pekko-http/pull/684#issuecomment-2922429986
I'd try to keep it generic and not invent new names, either keep calling it
`Trailer` or use `TrailerHeader`.
--
This is an automated message from the Apache Git Service.
To respond t
raboof commented on code in PR #684:
URL: https://github.com/apache/pekko-http/pull/684#discussion_r2115915132
##
http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/headers/headers.scala:
##
@@ -1226,3 +1225,70 @@ final case class `X-Real-Ip`(address: RemoteAddress)
pjfanning opened a new pull request, #1877:
URL: https://github.com/apache/pekko/pull/1877
relates to #1866
I've been focusing on the InitJoin message but @regiskuckaertz has pointed
out that configs are also exchanged in the InitJoinAck message.
I'm going to try to add test c
pjfanning commented on PR #1866:
URL: https://github.com/apache/pekko/pull/1866#issuecomment-2922002611
> Yes, I think the issue is with the config that goes in the `InitJoinAck`
that is sent back to the akka node, maybe it should be the same config that was
received in the `InitJoin`?
regiskuckaertz commented on PR #1866:
URL: https://github.com/apache/pekko/pull/1866#issuecomment-2921982680
Yes, I think the issue is with the config that goes in the `InitJoinAck`
that is sent back to the akka node, maybe it should be the same config that was
received in the `InitJoin`?
pjfanning commented on PR #1866:
URL: https://github.com/apache/pekko/pull/1866#issuecomment-2921956095
Thanks @regiskuckaertz. There is pre-existing code in SeedNodeProcess that
is meant to get Pekko nodes operating in an Akka cluster to put `akka` prefixed
configs in the InitJoin message.
regiskuckaertz commented on PR #1866:
URL: https://github.com/apache/pekko/pull/1866#issuecomment-2921873189
progress, the pekko node is now starting up and keeps accepting nodes:
```
2025-05-30 09:53:20,849 INFO [PTS-pekko.actor.default-dispatcher-11]
org.apache.pekko.cluster.Cluster
raboof commented on PR #1866:
URL: https://github.com/apache/pekko/pull/1866#issuecomment-2921538334
> I think there's a little mistake in the remote documentation:
That will get updated when the version is actually released. We should
probably highlight it in the release notes as wel
regiskuckaertz commented on PR #1866:
URL: https://github.com/apache/pekko/pull/1866#issuecomment-2921478435
ah right, I think there's a little mistake in the remote documentation:
from lo
18 matches
Mail list logo
