This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-management.git
The following commit(s) were added to refs/heads/main by this push:
new a21f353 change management port to 7626 (#54)
a21f353 is described below
commit a21f35343750c8c075980d9081a6c331a53c010a
Author: PJ Fanning <[email protected]>
AuthorDate: Tue Apr 18 12:49:11 2023 +0200
change management port to 7626 (#54)
---
.../resources/multi-container-pod-pending.json | 4 +-
.../src/test/resources/multi-container-pod.json | 4 +-
.../src/test/resources/docker-app.json | 2 +-
docs/src/main/paradox/bootstrap/istio.md | 12 ++--
docs/src/main/paradox/bootstrap/recipes.md | 36 +++++-----
docs/src/main/paradox/cluster-http-management.md | 2 +-
docs/src/main/paradox/discovery/aws.md | 6 +-
docs/src/main/paradox/discovery/kubernetes.md | 4 +-
.../paradox/kubernetes-deployment/deploying.md | 76 +++++++++++-----------
.../kubernetes-deployment/forming-a-cluster.md | 4 +-
.../preparing-for-production.md | 4 +-
docs/src/main/paradox/loglevels/log4j2.md | 6 +-
docs/src/main/paradox/loglevels/logback.md | 6 +-
docs/src/main/paradox/migration.md | 2 +
docs/src/main/paradox/pekko-management.md | 10 +--
integration-test/aws-api-ec2/README.md | 6 +-
.../pekko/cluster/bootstrap/IntegrationTest.scala | 6 +-
.../resources/CloudFormation/pekko-cluster.json | 18 ++---
integration-test/aws-api-ecs/README.md | 20 +++---
.../cfn-templates/ecs-integration-test-app.yaml | 16 ++---
.../pekko/cluster/bootstrap/EcsApiDemoApp.scala | 2 +-
.../dns-api-mesos/marathon/app.bridge-mode.json | 4 +-
.../src/main/resources/application.conf | 10 +--
.../kubernetes/pekko-cluster.yml | 6 +-
integration-test/kubernetes-api-java/pom.xml | 4 +-
integration-test/kubernetes-api/build.sbt | 2 +-
.../kubernetes-api/kubernetes/pekko-cluster.yml | 2 +-
integration-test/kubernetes-dns/build.sbt | 2 +-
.../kubernetes-dns/kubernetes/pekko-cluster.yml | 12 ++--
.../src/main/resources/application.conf | 4 +-
.../local/src/main/resources/application.conf | 6 +-
integration-test/marathon-api-docker/README.md | 2 +-
.../marathon/marathon-api-docker-app.json | 2 +-
.../src/main/resources/application.conf | 6 +-
.../src/main/resources/application.conf | 4 +-
.../bootstrap/LowestAddressJoinDeciderSpec.scala | 38 +++++------
.../internal/BootstrapCoordinatorSpec.scala | 32 ++++-----
management/src/main/resources/reference.conf | 2 +-
management/src/test/resources/reference.conf | 2 +-
.../PekkoManagementHttpEndpointSpec.scala | 2 +-
40 files changed, 195 insertions(+), 193 deletions(-)
diff --git
a/discovery-kubernetes-api/src/test/resources/multi-container-pod-pending.json
b/discovery-kubernetes-api/src/test/resources/multi-container-pod-pending.json
index d0c7c79..9ad494b 100644
---
a/discovery-kubernetes-api/src/test/resources/multi-container-pod-pending.json
+++
b/discovery-kubernetes-api/src/test/resources/multi-container-pod-pending.json
@@ -76,7 +76,7 @@
"failureThreshold": 5,
"httpGet": {
"path": "/alive",
- "port": 8558,
+ "port": 7626,
"scheme": "HTTP"
},
"periodSeconds": 10,
@@ -100,7 +100,7 @@
"failureThreshold": 5,
"httpGet": {
"path": "/ready",
- "port": 8558,
+ "port": 7626,
"scheme": "HTTP"
},
"periodSeconds": 10,
diff --git
a/discovery-kubernetes-api/src/test/resources/multi-container-pod.json
b/discovery-kubernetes-api/src/test/resources/multi-container-pod.json
index 2d7fbcd..985c201 100644
--- a/discovery-kubernetes-api/src/test/resources/multi-container-pod.json
+++ b/discovery-kubernetes-api/src/test/resources/multi-container-pod.json
@@ -76,7 +76,7 @@
"failureThreshold": 5,
"httpGet": {
"path": "/alive",
- "port": 8558,
+ "port": 7626,
"scheme": "HTTP"
},
"periodSeconds": 10,
@@ -100,7 +100,7 @@
"failureThreshold": 5,
"httpGet": {
"path": "/ready",
- "port": 8558,
+ "port": 7626,
"scheme": "HTTP"
},
"periodSeconds": 10,
diff --git a/discovery-marathon-api/src/test/resources/docker-app.json
b/discovery-marathon-api/src/test/resources/docker-app.json
index ac723f9..296413c 100644
--- a/discovery-marathon-api/src/test/resources/docker-app.json
+++ b/discovery-marathon-api/src/test/resources/docker-app.json
@@ -38,7 +38,7 @@
"labels": {}
},
{
- "containerPort": 8558,
+ "containerPort": 7626,
"hostPort": 0,
"servicePort": 10206,
"protocol": "tcp",
diff --git a/docs/src/main/paradox/bootstrap/istio.md
b/docs/src/main/paradox/bootstrap/istio.md
index ba95983..366dc31 100644
--- a/docs/src/main/paradox/bootstrap/istio.md
+++ b/docs/src/main/paradox/bootstrap/istio.md
@@ -4,17 +4,17 @@
To bootstrap a Pekko cluster in Istio, Istio must be configured to allow Pekko
cluster communication to bypass the Istio sidecar proxy. Istio's routing design
is made such that services don't need to be aware of each others location, they
just communicate with the proxy, and the mesh figures out how to route and
secure the communication. However, Pekko cluster communication is fundamentally
location aware, in order to, for example, route messages to sharded actors.
Hence a service mesh i [...]
-It is important to be aware that since Istio's proxy is bypassed, the Pekko
cluster communication will not be secured by Istio using TLS. If you wish to
secure your cluster communication, you will need to configure [Akka remoting
with
mTLS](https://doc.akka.io/docs/akka/current/remoting-artery.html#remote-security)
yourself.
+It is important to be aware that since Istio's proxy is bypassed, the Pekko
cluster communication will not be secured by Istio using TLS. If you wish to
secure your cluster communication, you will need to configure [Akka remoting
with
mTLS](https://pekko.apache.org/docs/pekko/current/remoting-artery.html#remote-security)
yourself.
Booting a Pekko cluster in Istio requires a minimum Istio version of 1.2.0, as
it requires the outbound port exclusions feature that was added in there. It
also requires using the @ref[Kubernetes API](kubernetes-api.md) contact point
discovery method to be used. The instructions below are for the additional
configuration necessary to ensure an Akka cluster can be bootstrapped in Istio.
## Allowing outbound communication
-By default, Istio redirects all outbound communication to its proxy. To
prevent it from doing this for Pekko cluster communication, both the remoting
and management ports need to be excluded from redirection. This can be done
using the `traffic.sidecar.istio.io/excludeOutboundPorts` annotation in the
deployment pod template. If your remoting port is 2552, and management port is
8558, this can be done like so:
+By default, Istio redirects all outbound communication to its proxy. To
prevent it from doing this for Pekko cluster communication, both the remoting
and management ports need to be excluded from redirection. This can be done
using the `traffic.sidecar.istio.io/excludeOutboundPorts` annotation in the
deployment pod template. If your remoting port is 7355, and management port is
7626, this can be done like so:
```yaml
annotations:
- traffic.sidecar.istio.io/excludeOutboundPorts: "2552,8558"
+ traffic.sidecar.istio.io/excludeOutboundPorts: "7355,7626"
```
## Allowing inbound communication
@@ -50,7 +50,7 @@ spec:
app: my-service
annotations:
traffic.sidecar.istio.io/includeInboundPorts: "8080"
- traffic.sidecar.istio.io/excludeOutboundPorts: "2552,8558"
+ traffic.sidecar.istio.io/excludeOutboundPorts: "7355,7626"
spec:
containers:
- name: my-service
@@ -59,9 +59,9 @@ spec:
ports:
- containerPort: 8080
name: http
- - containerPort: 2552
+ - containerPort: 7355
name: remoting
- - containerPort: 8558
+ - containerPort: 7626
name: management
readinessProbe:
diff --git a/docs/src/main/paradox/bootstrap/recipes.md
b/docs/src/main/paradox/bootstrap/recipes.md
index db9ba2c..a702472 100644
--- a/docs/src/main/paradox/bootstrap/recipes.md
+++ b/docs/src/main/paradox/bootstrap/recipes.md
@@ -199,25 +199,25 @@ $ kubectl logs $POD --follow | less
```
[INFO] [12/13/2018 07:13:42.867] [main] [ClusterBootstrap(pekko://default)]
Initiating bootstrap procedure using pekko.discovery.pekko-dns method...
-[DEBUG] [12/13/2018 07:13:42.906] [default-akka.actor.default-dispatcher-2]
[TimerScheduler(pekko://default)] Start timer [resolve-key] with generation [1]
-[DEBUG] [12/13/2018 07:13:42.919] [default-akka.actor.default-dispatcher-2]
[TimerScheduler(pekko://default)] Start timer [decide-key] with generation [2]
-[INFO] [12/13/2018 07:13:42.924] [default-akka.actor.default-dispatcher-2]
[pekko.tcp://[email protected]:2552/system/bootstrapCoordinator] Locating
service members. Using discovery
[pekko.discovery.dns.DnsSimpleServiceDiscovery], join decider
[org.apache.pekko.management.cluster.bootstrap.LowestAddressJoinDecider]
-[INFO] [12/13/2018 07:13:42.933] [default-akka.actor.default-dispatcher-2]
[pekko.tcp://[email protected]:2552/system/bootstrapCoordinator] Looking up
[Lookup(integration-test-kubernetes-dns-internal.pekko-bootstrap.svc.cluster.local,Some(management),Some(tcp))]
-[DEBUG] [12/13/2018 07:13:42.936] [default-akka.actor.default-dispatcher-2]
[DnsSimpleServiceDiscovery(pekko://default)] Lookup
[Lookup(integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local,Some(management),Some(tcp))]
translated to SRV query
[_management._tcp.integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local]
as contains portName and protocol
-[DEBUG] [12/13/2018 07:13:42.995] [default-akka.actor.default-dispatcher-18]
[pekko.tcp://[email protected]:2552/system/IO-DNS] Resolution request for
_management._tcp.integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local
Srv from Actor[pekko://default/temp/$a]
-[DEBUG] [12/13/2018 07:13:43.011] [default-akka.actor.default-dispatcher-6]
[pekko.tcp://[email protected]:2552/system/IO-DNS/async-dns/$a] Attempting to
resolve
_management._tcp.integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local
with Actor[pekko://default/system/IO-DNS/async-dns/$a/$a#1272991285]
-[DEBUG] [12/13/2018 07:13:43.049] [default-akka.actor.default-dispatcher-18]
[pekko.tcp://[email protected]:2552/system/IO-TCP/selectors/$a/0] Successfully
bound to /0.0.0.0:8558
-[DEBUG] [12/13/2018 07:13:43.134] [default-akka.actor.default-dispatcher-18]
[pekko.tcp://[email protected]:2552/system/IO-DNS/async-dns/$a/$a] Resolving
[_management._tcp.integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local]
(SRV)
-[INFO] [12/13/2018 07:13:43.147] [default-akka.actor.default-dispatcher-6]
[PekkoManagement(pekko://default)] Bound Pekko Management (HTTP) endpoint to:
0.0.0.0:8558
-[DEBUG] [12/13/2018 07:13:43.156] [default-akka.actor.default-dispatcher-5]
[pekko.tcp://[email protected]:2552/system/IO-TCP/selectors/$a/1] Successfully
bound to /0.0.0.0:8080
+[DEBUG] [12/13/2018 07:13:42.906] [default-pekko.actor.default-dispatcher-2]
[TimerScheduler(pekko://default)] Start timer [resolve-key] with generation [1]
+[DEBUG] [12/13/2018 07:13:42.919] [default-pekko.actor.default-dispatcher-2]
[TimerScheduler(pekko://default)] Start timer [decide-key] with generation [2]
+[INFO] [12/13/2018 07:13:42.924] [default-pekko.actor.default-dispatcher-2]
[pekko.tcp://[email protected]:7355/system/bootstrapCoordinator] Locating
service members. Using discovery
[pekko.discovery.dns.DnsSimpleServiceDiscovery], join decider
[org.apache.pekko.management.cluster.bootstrap.LowestAddressJoinDecider]
+[INFO] [12/13/2018 07:13:42.933] [default-pekko.actor.default-dispatcher-2]
[pekko.tcp://[email protected]:7355/system/bootstrapCoordinator] Looking up
[Lookup(integration-test-kubernetes-dns-internal.pekko-bootstrap.svc.cluster.local,Some(management),Some(tcp))]
+[DEBUG] [12/13/2018 07:13:42.936] [default-pekko.actor.default-dispatcher-2]
[DnsSimpleServiceDiscovery(pekko://default)] Lookup
[Lookup(integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local,Some(management),Some(tcp))]
translated to SRV query
[_management._tcp.integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local]
as contains portName and protocol
+[DEBUG] [12/13/2018 07:13:42.995] [default-pekko.actor.default-dispatcher-18]
[pekko.tcp://[email protected]:7355/system/IO-DNS] Resolution request for
_management._tcp.integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local
Srv from Actor[pekko://default/temp/$a]
+[DEBUG] [12/13/2018 07:13:43.011] [default-pekko.actor.default-dispatcher-6]
[pekko.tcp://[email protected]:7355/system/IO-DNS/async-dns/$a] Attempting to
resolve
_management._tcp.integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local
with Actor[pekko://default/system/IO-DNS/async-dns/$a/$a#1272991285]
+[DEBUG] [12/13/2018 07:13:43.049] [default-pekko.actor.default-dispatcher-18]
[pekko.tcp://[email protected]:7355/system/IO-TCP/selectors/$a/0] Successfully
bound to /0.0.0.0:7626
+[DEBUG] [12/13/2018 07:13:43.134] [default-pekko.actor.default-dispatcher-18]
[pekko.tcp://[email protected]:7355/system/IO-DNS/async-dns/$a/$a] Resolving
[_management._tcp.integration-test-kubernetes-dns-internal.pekko-bootstrap-demo-ns.svc.cluster.local]
(SRV)
+[INFO] [12/13/2018 07:13:43.147] [default-pekko.actor.default-dispatcher-6]
[PekkoManagement(pekko://default)] Bound Pekko Management (HTTP) endpoint to:
0.0.0.0:7626
+[DEBUG] [12/13/2018 07:13:43.156] [default-pekko.actor.default-dispatcher-5]
[pekko.tcp://[email protected]:7355/system/IO-TCP/selectors/$a/1] Successfully
bound to /0.0.0.0:8080
[INFO] [12/13/2018 07:13:43.180] [main] [akka.actor.ActorSystemImpl(default)]
Server online at http://localhost:8080/
....
-[INFO] [12/13/2018 07:13:50.631] [default-akka.actor.default-dispatcher-5]
[org.apache.pekko.cluster.Cluster(pekko://default)] Cluster Node
[pekko.tcp://[email protected]:2552] - Welcome from
[pekko.tcp://[email protected]:2552]
+[INFO] [12/13/2018 07:13:50.631] [default-pekko.actor.default-dispatcher-5]
[org.apache.pekko.cluster.Cluster(pekko://default)] Cluster Node
[pekko.tcp://[email protected]:7355] - Welcome from
[pekko.tcp://[email protected]:7355]
[DEBUG] [12/13/2018 07:13:50.644]
[default-pekko.remote.default-remote-dispatcher-22]
[akka.serialization.Serialization(pekko://default)] Using serializer
[org.apache.pekko.cluster.protobuf.ClusterMessageSerializer] for message
[org.apache.pekko.cluster.GossipEnvelope]
-[INFO] [12/13/2018 07:13:50.659] [default-akka.actor.default-dispatcher-18]
[pekko.tcp://[email protected]:2552/user/$b] Cluster
pekko.tcp://[email protected]:2552 >>> MemberUp(Member(address =
pekko.tcp://[email protected]:2552, status = Up))
-[INFO] [12/13/2018 07:13:50.676] [default-akka.actor.default-dispatcher-20]
[pekko.tcp://[email protected]:2552/user/$b] Cluster
pekko.tcp://[email protected]:2552 >>> MemberJoined(Member(address =
pekko.tcp://[email protected]:2552, status = Joining))
-[INFO] [12/13/2018 07:13:50.716] [default-akka.actor.default-dispatcher-6]
[pekko.tcp://[email protected]:2552/user/$b] Cluster
pekko.tcp://[email protected]:2552 >>>
LeaderChanged(Some(pekko.tcp://[email protected]:2552))
-[INFO] [12/13/2018 07:13:50.720] [default-akka.actor.default-dispatcher-3]
[pekko.tcp://[email protected]:2552/user/$b] Cluster
pekko.tcp://[email protected]:2552 >>>
RoleLeaderChanged(dc-default,Some(pekko.tcp://[email protected]:2552))
-[INFO] [12/13/2018 07:13:50.727] [default-akka.actor.default-dispatcher-6]
[pekko.tcp://[email protected]:2552/user/$b] Cluster
pekko.tcp://[email protected]:2552 >>>
SeenChanged(true,Set(pekko.tcp://[email protected]:2552,
pekko.tcp://[email protected]:2552))
-[INFO] [12/13/2018 07:13:50.733] [default-akka.actor.default-dispatcher-5]
[pekko.tcp://[email protected]:2552/user/$b] Cluster
pekko.tcp://[email protected]:2552 >>> ReachabilityChanged()
+[INFO] [12/13/2018 07:13:50.659] [default-pekko.actor.default-dispatcher-18]
[pekko.tcp://[email protected]:7355/user/$b] Cluster
pekko.tcp://[email protected]:7355 >>> MemberUp(Member(address =
pekko.tcp://[email protected]:7355, status = Up))
+[INFO] [12/13/2018 07:13:50.676] [default-pekko.actor.default-dispatcher-20]
[pekko.tcp://[email protected]:7355/user/$b] Cluster
pekko.tcp://[email protected]:7355 >>> MemberJoined(Member(address =
pekko.tcp://[email protected]:7355, status = Joining))
+[INFO] [12/13/2018 07:13:50.716] [default-pekko.actor.default-dispatcher-6]
[pekko.tcp://[email protected]:7355/user/$b] Cluster
pekko.tcp://[email protected]:7355 >>>
LeaderChanged(Some(pekko.tcp://[email protected]:7355))
+[INFO] [12/13/2018 07:13:50.720] [default-pekko.actor.default-dispatcher-3]
[pekko.tcp://[email protected]:7355/user/$b] Cluster
pekko.tcp://[email protected]:7355 >>>
RoleLeaderChanged(dc-default,Some(pekko.tcp://[email protected]:7355))
+[INFO] [12/13/2018 07:13:50.727] [default-pekko.actor.default-dispatcher-6]
[pekko.tcp://[email protected]:7355/user/$b] Cluster
pekko.tcp://[email protected]:7355 >>>
SeenChanged(true,Set(pekko.tcp://[email protected]:7355,
pekko.tcp://[email protected]:7355))
+[INFO] [12/13/2018 07:13:50.733] [default-pekko.actor.default-dispatcher-5]
[pekko.tcp://[email protected]:7355/user/$b] Cluster
pekko.tcp://[email protected]:7355 >>> ReachabilityChanged()
```
diff --git a/docs/src/main/paradox/cluster-http-management.md
b/docs/src/main/paradox/cluster-http-management.md
index 7ff95bf..4d1ab71 100644
--- a/docs/src/main/paradox/cluster-http-management.md
+++ b/docs/src/main/paradox/cluster-http-management.md
@@ -104,7 +104,7 @@ In the paths `address` is also allowed to be provided
without the protocol prefi
Example request:
GET /cluster/domain-events?type=MemberUp&type=LeaderChanged HTTP/1.1
- Host: 192.168.1.23:8558
+ Host: 192.168.1.23:7626
Example response:
diff --git a/docs/src/main/paradox/discovery/aws.md
b/docs/src/main/paradox/discovery/aws.md
index 817ea40..c6f5e43 100644
--- a/docs/src/main/paradox/discovery/aws.md
+++ b/docs/src/main/paradox/discovery/aws.md
@@ -112,7 +112,7 @@ a setup with multiple Pekko nodes (i.e. multiple JVMs) per
EC2 instance.
pekko {
discovery {
aws-api-ec2-tag-based {
- ports = [8557, 8558, 8559] # 3 Pekko nodes per EC2 instance
+ ports = [7625, 7626, 7627] # 3 Pekko nodes per EC2 instance
# note that the above need to be the ports associated with the
*Pekko Management* extension
}
}
@@ -275,8 +275,8 @@ Notes:
* Because ECS service discovery is only able to discover IP addresses (not
ports
too) you'll need to set
- `pekko.management.cluster.bootstrap.contact-point.fallback-port = 8558`,
where
- 8558 is whatever port you choose to bind pekko-management to.
+ `pekko.management.cluster.bootstrap.contact-point.fallback-port = 7626`,
where
+ 7626 is whatever port you choose to bind pekko-management to.
* You can set additional filters to only discover nodes with specific tag
values in
your application.conf file, in the `pekko.discovery.aws-api-ecs-async.tags`
key.
diff --git a/docs/src/main/paradox/discovery/kubernetes.md
b/docs/src/main/paradox/discovery/kubernetes.md
index 9d73151..dc1ad16 100644
--- a/docs/src/main/paradox/discovery/kubernetes.md
+++ b/docs/src/main/paradox/discovery/kubernetes.md
@@ -98,13 +98,13 @@ spec:
ports:
# pekko remoting
- name: remoting
- containerPort: 2552
+ containerPort: 7355
protocol: TCP
# When
# pekko.management.cluster.bootstrap.contact-point-discovery.port-name
# is defined, it must correspond to this name:
- name: management
- containerPort: 8558
+ containerPort: 7626
protocol: TCP
```
diff --git a/docs/src/main/paradox/kubernetes-deployment/deploying.md
b/docs/src/main/paradox/kubernetes-deployment/deploying.md
index e8317c1..5146354 100644
--- a/docs/src/main/paradox/kubernetes-deployment/deploying.md
+++ b/docs/src/main/paradox/kubernetes-deployment/deploying.md
@@ -59,46 +59,46 @@ make the logs quieter, but for now it will help us to
understand what is happeni
@@@vars
```
-1 [INFO] [org.apache.pekko.remote.artery.tcp.ArteryTcpTransport] - Remoting
started with transport [Artery tcp]; listening on address
[pekko://[email protected]:25520] with UID [4609278524397890522] MDC:
{pekkoAddress=pekko://[email protected]:25520, sourceThread=main,
akkaSource=ArteryTcpTransport(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:51.188UTC}
- [INFO] [org.apache.pekko.cluster.Cluster] []
[Appka-akka.actor.default-dispatcher-3] - Cluster Node
[pekko://[email protected]:25520] - Starting up, Akka version [2.6.5] ... MDC:
{pekkoAddress=pekko://[email protected]:25520, sourceThread=main,
akkaSource=Cluster(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:51.240UTC}
- [INFO] [org.apache.pekko.cluster.Cluster] []
[Appka-akka.actor.default-dispatcher-6] - Cluster Node
[pekko://[email protected]:25520] - No seed-nodes configured, manual cluster
join required, see
https://doc.akka.io/docs/akka/current/typed/cluster.html#joining MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.internal-dispatcher-5,
akkaSource=Cluster(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:51.619UTC}
- [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-akka.actor.default-dispatcher-6] - Started [pekko://Appka],
cluster.selfAddress = pekko://[email protected]:25520) MDC:
{pekkoAddress=pekko://[email protected]:25520, akkaSource=pekko://Appka/user,
sourceActorSystem=Appka}
-
-2a [INFO] [org.apache.management.internal.HealthChecksImpl] []
[Appka-akka.actor.default-dispatcher-3] - Loading readiness checks
[(cluster-membership,org.apache.pekko.management.cluster.scaladsl.ClusterMembershipCheck),
(example-ready,org.apache.pekko.cluster.bootstrap.demo.DemoHealthCheck)] MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=HealthChecksImpl(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.510UTC}
- [INFO] [org.apache.management.internal.HealthChecksImpl] []
[Appka-akka.actor.default-dispatcher-3] - Loading liveness checks [] MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=HealthChecksImpl(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.510UTC}
- [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement] []
[Appka-akka.actor.default-dispatcher-13] - Binding Pekko Management (HTTP)
endpoint to: 172.17.0.6:8558 MDC: {pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.534UTC}
-
-2b [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement] []
[Appka-akka.actor.default-dispatcher-3] - Including HTTP management routes for
ClusterHttpManagementRouteProvider MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.546UTC}
- [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement] []
[Appka-akka.actor.default-dispatcher-3] - Including HTTP management routes for
ClusterBootstrap MDC: {pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.620UTC}
- [INFO] [org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap] []
[Appka-akka.actor.default-dispatcher-3] - Using self contact point address:
http://172.17.0.6:8558 MDC: {pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=ClusterBootstrap(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.624UTC}
- [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement] []
[Appka-akka.actor.default-dispatcher-3] - Including HTTP management routes for
HealthCheckRoutes MDC: {pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.651UTC}
- [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement]
[akkaManagementBound] [Appka-akka.actor.default-dispatcher-3] - Bound Pekko
Management (HTTP) endpoint to: 172.17.0.6:8558 MDC:
{pekkoAddress=pekko://[email protected]:25520, akkaHttpAddress=172.17.0.6:8558,
sourceThread=Appka-akka.actor.default-dispatcher-13,
akkaSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.692UTC}
-
-3 [INFO] [org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap] []
[Appka-akka.actor.default-dispatcher-3] - Initiating bootstrap procedure using
kubernetes-api method... MDC: {pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=ClusterBootstrap(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.671UTC}
- [INFO] [org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap] []
[Appka-akka.actor.default-dispatcher-3] - Bootstrap using `pekko.discovery`
method: kubernetes-api MDC: {pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-6,
akkaSource=ClusterBootstrap(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:04:53.673UTC}
-
-4 [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[akkaBootstrapInit] [Appka-akka.actor.default-dispatcher-3] - Locating service
members. Using discovery
[pekko.discovery.kubernetes.KubernetesApiServiceDiscovery], join decider
[org.apache.pekko.management.cluster.bootstrap.LowestAddressJoinDecider],
scheme [http] MDC: {pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-13,
akkaSource=pekko://Appka/system/boo [...]
- [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[] [Appka-akka.actor.default-dispatcher-3] - Looking up
[Lookup(appka,None,Some(tcp))] MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-13,
akkaSource=pekko://Appka/system/bootstrapCoordinator, sourceActorSystem=Appka,
akkaTimestamp=10:04:53.844UTC}
- [INFO]
[org.apache.pekko.discovery.kubernetes.KubernetesApiServiceDiscovery] []
[Appka-akka.actor.default-dispatcher-3] - Querying for pods with label
selector: [app=appka]. Namespace: [appka-1]. Port: [None] MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-13,
akkaSource=KubernetesApiServiceDiscovery(pekko://Appka),
sourceActorSystem=Appka, akkaTimestamp=10:04:53.844UTC}
-
-5 [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[akkaBootstrapResolved] [Appka-akka.actor.default-dispatcher-3] - Located
service members based on: [Lookup(appka,None,Some(tcp))]:
[ResolvedTarget(172-17-0-6.appka-1.pod.cluster.local,None,Some(/172.17.0.6)),
ResolvedTarget(172-17-0-7.appka-1.pod.cluster.local,None,Some(/172.17.0.7)),
ResolvedTarget(172-17-0-5.appka-1.pod.cluster.local,None,Some(/172.17.0.5))],
filtered to [172-17-0-5.appka-1.pod.clu [...]
-
-6 [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[akkaBootstrapSeedNodes] [Appka-akka.actor.default-dispatcher-20] - Contact
point [pekko://[email protected]:25520] returned [1] seed-nodes
[pekko://[email protected]:25520] MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-11,
akkaSource=pekko://Appka/system/bootstrapCoordinator, sourceActorSystem=Appka,
akkaTimestamp=10:05:01.306UTC, pekkoSeedNodes=pek [...]
- [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[akkaBootstrapJoin] [Appka-akka.actor.default-dispatcher-20] - Joining
[pekko://[email protected]:25520] to existing cluster
[pekko://[email protected]:25520] MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-11,
akkaSource=pekko://Appka/system/bootstrapCoordinator, sourceActorSystem=Appka,
akkaTimestamp=10:05:01.309UTC, pekkoSeedNodes=pekko://Appka@172. [...]
-
-7 [INFO] [org.apache.pekko.cluster.Cluster] []
[Appka-akka.actor.default-dispatcher-11] - Cluster Node
[pekko://[email protected]:25520] - Welcome from
[pekko://[email protected]:25520] MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.internal-dispatcher-2,
akkaSource=Cluster(pekko://Appka), sourceActorSystem=Appka,
akkaTimestamp=10:05:01.918UTC}
- [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-akka.actor.default-dispatcher-19] - MemberEvent: MemberUp(Member(address
= pekko://[email protected]:25520, status = Up)) MDC:
{pekkoAddress=pekko://[email protected]:25520, akkaSource=pekko://Appka/user,
sourceActorSystem=Appka}
- [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-akka.actor.default-dispatcher-19] - MemberEvent:
MemberJoined(Member(address = pekko://[email protected]:25520, status =
Joining)) MDC: {pekkoAddress=pekko://[email protected]:25520,
akkaSource=pekko://Appka/user, sourceActorSystem=Appka}
- [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-akka.actor.default-dispatcher-19] - MemberEvent:
MemberJoined(Member(address = pekko://[email protected]:25520, status =
Joining)) MDC: {pekkoAddress=pekko://[email protected]:25520,
akkaSource=pekko://Appka/user, sourceActorSystem=Appka}
- [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-akka.actor.default-dispatcher-19] - MemberEvent: MemberUp(Member(address
= pekko://[email protected]:25520, status = Up)) MDC:
{pekkoAddress=pekko://[email protected]:25520, akkaSource=pekko://Appka/user,
sourceActorSystem=Appka}
- [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-akka.actor.default-dispatcher-19] - MemberEvent: MemberUp(Member(address
= pekko://[email protected]:25520, status = Up)) MDC:
{pekkoAddress=pekko://[email protected]:25520, akkaSource=pekko://Appka/user,
sourceActorSystem=Appka}
+1 [INFO] [org.apache.pekko.remote.artery.tcp.ArteryTcpTransport] - Remoting
started with transport [Artery tcp]; listening on address
[pekko://[email protected]:17355] with UID [4609278524397890522] MDC:
{pekkoAddress=pekko://[email protected]:17355, sourceThread=main,
pekkoSource=ArteryTcpTransport(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:51.188UTC}
+ [INFO] [org.apache.pekko.cluster.Cluster] []
[Appka-pekko.actor.default-dispatcher-3] - Cluster Node
[pekko://[email protected]:17355] - Starting up, Akka version [2.6.5] ... MDC:
{pekkoAddress=pekko://[email protected]:17355, sourceThread=main,
pekkoSource=Cluster(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:51.240UTC}
+ [INFO] [org.apache.pekko.cluster.Cluster] []
[Appka-pekko.actor.default-dispatcher-6] - Cluster Node
[pekko://[email protected]:17355] - No seed-nodes configured, manual cluster
join required, see
https://pekko.apache.org/docs/pekko/current/typed/cluster.html#joining MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.internal-dispatcher-5,
pekkoSource=Cluster(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:51.619UTC}
+ [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-pekko.actor.default-dispatcher-6] - Started [pekko://Appka],
cluster.selfAddress = pekko://[email protected]:17355) MDC:
{pekkoAddress=pekko://[email protected]:17355, pekkoSource=pekko://Appka/user,
sourceActorSystem=Appka}
+
+2a [INFO] [org.apache.management.internal.HealthChecksImpl] []
[Appka-pekko.actor.default-dispatcher-3] - Loading readiness checks
[(cluster-membership,org.apache.pekko.management.cluster.scaladsl.ClusterMembershipCheck),
(example-ready,org.apache.pekko.cluster.bootstrap.demo.DemoHealthCheck)] MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=HealthChecksImpl(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53 [...]
+ [INFO] [org.apache.management.internal.HealthChecksImpl] []
[Appka-pekko.actor.default-dispatcher-3] - Loading liveness checks [] MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=HealthChecksImpl(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.510UTC}
+ [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement] []
[Appka-pekko.actor.default-dispatcher-13] - Binding Pekko Management (HTTP)
endpoint to: 172.17.0.6:7626 MDC: {pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.534UTC}
+
+2b [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement] []
[Appka-pekko.actor.default-dispatcher-3] - Including HTTP management routes for
ClusterHttpManagementRouteProvider MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.546UTC}
+ [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement] []
[Appka-pekko.actor.default-dispatcher-3] - Including HTTP management routes for
ClusterBootstrap MDC: {pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.620UTC}
+ [INFO] [org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap] []
[Appka-pekko.actor.default-dispatcher-3] - Using self contact point address:
http://172.17.0.6:7626 MDC: {pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=ClusterBootstrap(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.624UTC}
+ [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement] []
[Appka-pekko.actor.default-dispatcher-3] - Including HTTP management routes for
HealthCheckRoutes MDC: {pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.651UTC}
+ [INFO] [org.apache.pekko.management.scaladsl.PekkoManagement]
[pekkoManagementBound] [Appka-pekko.actor.default-dispatcher-3] - Bound Pekko
Management (HTTP) endpoint to: 172.17.0.6:7626 MDC:
{pekkoAddress=pekko://[email protected]:17355, pekkoHttpAddress=172.17.0.6:7626,
sourceThread=Appka-pekko.actor.default-dispatcher-13,
pekkoSource=PekkoManagement(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.692UTC}
+
+3 [INFO] [org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap] []
[Appka-pekko.actor.default-dispatcher-3] - Initiating bootstrap procedure using
kubernetes-api method... MDC: {pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=ClusterBootstrap(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.671UTC}
+ [INFO] [org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap] []
[Appka-pekko.actor.default-dispatcher-3] - Bootstrap using `pekko.discovery`
method: kubernetes-api MDC: {pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-6,
pekkoSource=ClusterBootstrap(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.673UTC}
+
+4 [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[pekkoBootstrapInit] [Appka-pekko.actor.default-dispatcher-3] - Locating
service members. Using discovery
[pekko.discovery.kubernetes.KubernetesApiServiceDiscovery], join decider
[org.apache.pekko.management.cluster.bootstrap.LowestAddressJoinDecider],
scheme [http] MDC: {pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-13,
pekkoSource=pekko://Appka/system [...]
+ [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[] [Appka-pekko.actor.default-dispatcher-3] - Looking up
[Lookup(appka,None,Some(tcp))] MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-13,
pekkoSource=pekko://Appka/system/bootstrapCoordinator, sourceActorSystem=Appka,
pekkoTimestamp=10:04:53.844UTC}
+ [INFO]
[org.apache.pekko.discovery.kubernetes.KubernetesApiServiceDiscovery] []
[Appka-pekko.actor.default-dispatcher-3] - Querying for pods with label
selector: [app=appka]. Namespace: [appka-1]. Port: [None] MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-13,
pekkoSource=KubernetesApiServiceDiscovery(pekko://Appka),
sourceActorSystem=Appka, pekkoTimestamp=10:04:53.844UTC}
+
+5 [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[pekkoBootstrapResolved] [Appka-pekko.actor.default-dispatcher-3] - Located
service members based on: [Lookup(appka,None,Some(tcp))]:
[ResolvedTarget(172-17-0-6.appka-1.pod.cluster.local,None,Some(/172.17.0.6)),
ResolvedTarget(172-17-0-7.appka-1.pod.cluster.local,None,Some(/172.17.0.7)),
ResolvedTarget(172-17-0-5.appka-1.pod.cluster.local,None,Some(/172.17.0.5))],
filtered to [172-17-0-5.appka-1.pod.c [...]
+
+6 [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[pekkoBootstrapSeedNodes] [Appka-pekko.actor.default-dispatcher-20] - Contact
point [pekko://[email protected]:17355] returned [1] seed-nodes
[pekko://[email protected]:17355] MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-11,
pekkoSource=pekko://Appka/system/bootstrapCoordinator, sourceActorSystem=Appka,
pekkoTimestamp=10:05:01.306UTC, pekkoSeedNode [...]
+ [INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[pekkoBootstrapJoin] [Appka-pekko.actor.default-dispatcher-20] - Joining
[pekko://[email protected]:17355] to existing cluster
[pekko://[email protected]:17355] MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-11,
pekkoSource=pekko://Appka/system/bootstrapCoordinator, sourceActorSystem=Appka,
pekkoTimestamp=10:05:01.309UTC, pekkoSeedNodes=pekko://Appka [...]
+
+7 [INFO] [org.apache.pekko.cluster.Cluster] []
[Appka-pekko.actor.default-dispatcher-11] - Cluster Node
[pekko://[email protected]:17355] - Welcome from
[pekko://[email protected]:17355] MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.internal-dispatcher-2,
pekkoSource=Cluster(pekko://Appka), sourceActorSystem=Appka,
pekkoTimestamp=10:05:01.918UTC}
+ [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-pekko.actor.default-dispatcher-19] - MemberEvent:
MemberUp(Member(address = pekko://[email protected]:17355, status = Up)) MDC:
{pekkoAddress=pekko://[email protected]:17355, pekkoSource=pekko://Appka/user,
sourceActorSystem=Appka}
+ [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-pekko.actor.default-dispatcher-19] - MemberEvent:
MemberJoined(Member(address = pekko://[email protected]:17355, status =
Joining)) MDC: {pekkoAddress=pekko://[email protected]:17355,
pekkoSource=pekko://Appka/user, sourceActorSystem=Appka}
+ [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-pekko.actor.default-dispatcher-19] - MemberEvent:
MemberJoined(Member(address = pekko://[email protected]:17355, status =
Joining)) MDC: {pekkoAddress=pekko://[email protected]:17355,
pekkoSource=pekko://Appka/user, sourceActorSystem=Appka}
+ [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-pekko.actor.default-dispatcher-19] - MemberEvent:
MemberUp(Member(address = pekko://[email protected]:17355, status = Up)) MDC:
{pekkoAddress=pekko://[email protected]:17355, pekkoSource=pekko://Appka/user,
sourceActorSystem=Appka}
+ [INFO] [org.apache.pekko.cluster.bootstrap.demo.DemoApp] []
[Appka-pekko.actor.default-dispatcher-19] - MemberEvent:
MemberUp(Member(address = pekko://[email protected]:17355, status = Up)) MDC:
{pekkoAddress=pekko://[email protected]:17355, pekkoSource=pekko://Appka/user,
sourceActorSystem=Appka}
```
@@@
An explanation of these messages is as follows.
-1. These are init messages, showing that remoting has started on port 25520.
The IP address should be the pods IP address from which other pods can access
it, while the port number should match the configured remoting number,
defaulting to 25520.
-2. Init messages for Pekko management, once again, the IP address should be
the pods IP address, while the port number should be the port number you've
configured for Pekko management to use, defaulting to 8558.
+1. These are init messages, showing that remoting has started on port 17355.
The IP address should be the pods IP address from which other pods can access
it, while the port number should match the configured remoting number,
defaulting to 17355.
+2. Init messages for Pekko management, once again, the IP address should be
the pods IP address, while the port number should be the port number you've
configured for Pekko management to use, defaulting to 7626.
Pekko management is also hosting the readiness and liveness checks.
3. Now the cluster bootstrap process is starting. The service name should
match your Pekko system name or configured service name in cluster bootstrap,
and the port should match your configured port name. In this guide we kept
these as the default values.
This and subsequent messages will be repeated many times as cluster
bootstrap polls Kubernetes and the other pods to determine what pods have been
started, and whether and where a cluster has been formed.
@@ -115,7 +115,7 @@ and ends up joining a pod with IP `172.17.0.5` as it has a
lower IP.
If you look in the logs of that pod, you'll see a message like this:
```
-[INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[akkaBootstrapJoinSelf] [Appka-akka.actor.default-dispatcher-19] - Initiating
new cluster, self-joining [pekko://[email protected]:25520]. Other nodes are
expected to locate this cluster via continued contact-point probing. MDC:
{pekkoAddress=pekko://[email protected]:25520,
sourceThread=Appka-akka.actor.default-dispatcher-11,
akkaSource=pekko://Appka/system/bootstrapCoordinator, sourceActorSystem=Appka,
a [...]
+[INFO]
[org.apache.pekko.management.cluster.bootstrap.internal.BootstrapCoordinator]
[pekkoBootstrapJoinSelf] [Appka-pekko.actor.default-dispatcher-19] - Initiating
new cluster, self-joining [pekko://[email protected]:17355]. Other nodes are
expected to locate this cluster via continued contact-point probing. MDC:
{pekkoAddress=pekko://[email protected]:17355,
sourceThread=Appka-pekko.actor.default-dispatcher-11,
pekkoSource=pekko://Appka/system/bootstrapCoordinator, sourceActorSystem=Appk
[...]
```
This message will appear after a timeout called the stable margin, which
defaults to 5 seconds, at that point, the pod has seen that there have been no
changes to the number of pods deployed for 5 seconds, and so given that it has
the lowest IP address, it considers it safe for it to start a new cluster.
@@ -150,7 +150,7 @@ for 'hello world':
kubectl expose deployment appka --type=LoadBalancer --name=appka-service
-You can inspect the Pekko Cluster membership status with the [Cluster HTTP
Management](https://doc.akka.io/docs/akka-management/current/cluster-http-management.html).
+You can inspect the Pekko Cluster membership status with the [Cluster HTTP
Management](https://doc.pekko.io/docs/pekko-management/current/cluster-http-management.html).
- curl http://127.0.0.1:8558/cluster/members/
+ curl http://127.0.0.1:7626/cluster/members/
diff --git a/docs/src/main/paradox/kubernetes-deployment/forming-a-cluster.md
b/docs/src/main/paradox/kubernetes-deployment/forming-a-cluster.md
index 464e4b9..7bc5658 100644
--- a/docs/src/main/paradox/kubernetes-deployment/forming-a-cluster.md
+++ b/docs/src/main/paradox/kubernetes-deployment/forming-a-cluster.md
@@ -64,7 +64,7 @@ pekko {
```
### Apache Pekko Management HTTP
-The default configuration for Pekko management HTTP is suitable for use in
Kubernetes, it will bind to a default port of 8558 on the pods external IP
address.
+The default configuration for Pekko management HTTP is suitable for use in
Kubernetes, it will bind to a default port of 7626 on the pods external IP
address.
### Apache Pekko Cluster Bootstrap
@@ -179,7 +179,7 @@ Health check probes can be adjusted in
`kubernetes/pekko-cluster.yaml`:
```yaml
ports:
- name: management
- containerPort: 8558
+ containerPort: 7626
readinessProbe:
httpGet:
path: "/ready"
diff --git
a/docs/src/main/paradox/kubernetes-deployment/preparing-for-production.md
b/docs/src/main/paradox/kubernetes-deployment/preparing-for-production.md
index a406d99..980b218 100644
--- a/docs/src/main/paradox/kubernetes-deployment/preparing-for-production.md
+++ b/docs/src/main/paradox/kubernetes-deployment/preparing-for-production.md
@@ -51,7 +51,7 @@ spec:
port: management
ports:
- name: management
- containerPort: 8558
+ containerPort: 7626
protocol: TCP
- name: http
containerPort: 8080
@@ -73,7 +73,7 @@ Here are a few things to note:
We will discuss how to select an appropriate version number below.
* We've only requested minimal CPU to the pods for this service. This is
suitable for a local deployment, but you may wish to increase it if you're
deploying to a real deployment. Note that we also haven't set a CPU limit,
this is because it's
- [recommended that JVMs do not set a CPU
limit](https://doc.akka.io/docs/akka/current/additional/deploying.html#resource-limits).
+ [recommended that JVMs do not set a CPU
limit](https://pekko.apache.org/docs/pekko/current/additional/deploying.html#resource-limits).
* We've configured a liveness probe and readiness probe. These are provided
out of the box by Pekko Management and are discussed later.
## Image version number
diff --git a/docs/src/main/paradox/loglevels/log4j2.md
b/docs/src/main/paradox/loglevels/log4j2.md
index 6376f22..8cc8248 100644
--- a/docs/src/main/paradox/loglevels/log4j2.md
+++ b/docs/src/main/paradox/loglevels/log4j2.md
@@ -56,12 +56,12 @@ A HTTP `PUT` request to `loglevel/log4j2?logger=[logger
name]&level=[level name]
For example using curl:
```
-curl -X PUT
"http://127.0.0.1:8558/loglevel/log4j2?logger=com.example.MyActor&level=DEBUG";
+curl -X PUT
"http://127.0.0.1:7626/loglevel/log4j2?logger=com.example.MyActor&level=DEBUG";
```
#### Classic and Internal Pekko Logger Level
-Internal Pekko actors and classic Pekko does logging through the built in API
there is an [additional level of
filtering](https://doc.akka.io/docs/akka/current/logging.html#slf4j) using the
+Internal Pekko actors and classic Pekko does logging through the built in API
there is an [additional level of
filtering](https://pekko.apache.org/docs/pekko/current/logging.html#slf4j)
using the
`pekko.loglevel` setting. If you have not set `pekko.loglevel` to `DEBUG`
(recommended) log entries from the classic logging API may never reach the
logger backend at all.
The current level configured with `pekko.loglevel` can be inspected with a GET
request to `loglevel/pekko`.
@@ -72,5 +72,5 @@ Note that the allowed level for Pekko Classic logging is a
subset of the logleve
For example using curl:
```
-curl -X PUT "http://127.0.0.1:8558/loglevel/pekko?level=DEBUG";
+curl -X PUT "http://127.0.0.1:7626/loglevel/pekko?level=DEBUG";
```
diff --git a/docs/src/main/paradox/loglevels/logback.md
b/docs/src/main/paradox/loglevels/logback.md
index 22bffee..f6ae94e 100644
--- a/docs/src/main/paradox/loglevels/logback.md
+++ b/docs/src/main/paradox/loglevels/logback.md
@@ -56,12 +56,12 @@ A HTTP `PUT` request to `loglevel/logback?logger=[logger
name]&level=[level name
For example using curl:
```
-curl -X PUT
"http://127.0.0.1:8558/loglevel/logback?logger=com.example.MyActor&level=DEBUG";
+curl -X PUT
"http://127.0.0.1:7626/loglevel/logback?logger=com.example.MyActor&level=DEBUG";
```
#### Classic and Internal Pekko Logger Level
-Internal Pekko actors and classic Pekko does logging through the built in API
there is an [additional level of
filtering](https://doc.akka.io/docs/akka/current/logging.html#slf4j) using the
+Internal Pekko actors and classic Pekko does logging through the built in API
there is an [additional level of
filtering](https://pekko.apache.org/docs/pekko/current/logging.html#slf4j)
using the
`pekko.loglevel` setting. If you have not set `pekko.loglevel` to `DEBUG`
(recommended) log entries from the classic logging API may never reach the
logger backend at all.
The current level configured with `pekko.loglevel` can be inspected with a GET
request to `loglevel/pekko`.
@@ -72,5 +72,5 @@ Note that the allowed level for Pekko Classic logging is a
subset of the logleve
For example using curl:
```
-curl -X PUT "http://127.0.0.1:8558/loglevel/pekko?level=DEBUG";
+curl -X PUT "http://127.0.0.1:7626/loglevel/pekko?level=DEBUG";
```
diff --git a/docs/src/main/paradox/migration.md
b/docs/src/main/paradox/migration.md
index 91d1a9e..f8fce07 100644
--- a/docs/src/main/paradox/migration.md
+++ b/docs/src/main/paradox/migration.md
@@ -9,5 +9,7 @@ Version requirements:
When migrating from Akka Management it is recommended to first upgrade to Akka
2.6.20 / Akka Management 1.1.4 before switching to Pekko/Pekko Management.
Please refer to the [Akka Management migration
guide](https://doc.akka.io/docs/akka-management/current/migration.html).
+### Management Port
+The default port has changed from Akka's 8558 to Pekko's 7626.
diff --git a/docs/src/main/paradox/pekko-management.md
b/docs/src/main/paradox/pekko-management.md
index e75c759..a836fcf 100644
--- a/docs/src/main/paradox/pekko-management.md
+++ b/docs/src/main/paradox/pekko-management.md
@@ -72,12 +72,12 @@ application.conf
: ```hocon
# Get hostname from environmental variable HOST
pekko.management.http.hostname = ${HOST}
- # Use port 8558 by default, but use environment variable PORT_8558 if it is
defined
- pekko.management.http.port = 8558
- pekko.management.http.port = ${?PORT_8558}
- # Bind to 0.0.0.0:8558 'internally':
+ # Use port 7626 by default, but use environment variable PORT_7626 if it is
defined
+ pekko.management.http.port = 7626
+ pekko.management.http.port = ${?PORT_7626}
+ # Bind to 0.0.0.0:7626 'internally':
pekko.management.http.bind-hostname = 0.0.0.0
- pekko.management.http.bind-port = 8558
+ pekko.management.http.bind-port = 7626
```
It is also possible to modify the base path of the API, by setting the
appropriate value in application.conf:
diff --git a/integration-test/aws-api-ec2/README.md
b/integration-test/aws-api-ec2/README.md
index 9063300..bae3d62 100644
--- a/integration-test/aws-api-ec2/README.md
+++ b/integration-test/aws-api-ec2/README.md
@@ -40,12 +40,12 @@ Step 4: Create Security Group
-----------------------------
Since we want to run a Pekko cluster on these instances, they have to be able
to talk to each other: the TCP ports we
-care about are 2552 and 8558. However, we don't want to open these ports to
the whole wide world. In the Amazon Cloud,
+care about are 7355 and 7626. However, we don't want to open these ports to
the whole wide world. In the Amazon Cloud,
instances can *privately* communicate with each other if they are part of the
same security group *and* if the proper inbound
rules are set.
Create a security group called "pekko-cluster". Once the security group is
created, select it and go to "edit inbound rules".
-First, add a custom TCP rule to allow yourself ssh access (port: 22, source:
My IP). Then, add two custom TCP rules (for ports 8558, 2552)
+First, add a custom TCP rule to allow yourself ssh access (port: 22, source:
My IP). Then, add two custom TCP rules (for ports 7626, 7355)
using a custom source: the ID of the security group.
See the screenshot below.
@@ -102,7 +102,7 @@ Open a second terminal session to one of the EC2 instances:
```
$ MY_IP=`curl -s http://169.254.169.254/latest/meta-data/local-ipv4`
-$ curl -XGET http://$MY_IP:8558/cluster/members | python -mjson.tool
+$ curl -XGET http://$MY_IP:7626/cluster/members | python -mjson.tool
```
You should see two members with status equal to 'Up' and no unreachable
members.
diff --git
a/integration-test/aws-api-ec2/src/it/scala/org/apache/pekko/cluster/bootstrap/IntegrationTest.scala
b/integration-test/aws-api-ec2/src/it/scala/org/apache/pekko/cluster/bootstrap/IntegrationTest.scala
index 648b138..295d254 100644
---
a/integration-test/aws-api-ec2/src/it/scala/org/apache/pekko/cluster/bootstrap/IntegrationTest.scala
+++
b/integration-test/aws-api-ec2/src/it/scala/org/apache/pekko/cluster/bootstrap/IntegrationTest.scala
@@ -178,7 +178,7 @@ class IntegrationTest
private def readTemplateFromResourceFolder(path: String): String =
scala.io.Source.fromResource(path).mkString
// we need this in order to tell AWS to allow the machine running the
integration test to connect to the EC2 instances'
- // port 8558
+ // port 7626
private def getMyIp: String = {
val myIp: Future[(Int, String)] =
httpGetRequest("http://checkip.amazonaws.com";)
val result = Await.result(myIp, atMost = 3 seconds)
@@ -194,7 +194,7 @@ class IntegrationTest
clusterPublicIps should have size instanceCount
clusterPrivateIps should have size instanceCount
- val expectedNodes: Set[String] = clusterPrivateIps.map(ip =>
s"pekko.tcp://demo@$ip:2552").toSet
+ val expectedNodes: Set[String] = clusterPrivateIps.map(ip =>
s"pekko.tcp://demo@$ip:7355").toSet
eventually {
@@ -204,7 +204,7 @@ class IntegrationTest
clusterPublicIps.foreach { nodeIp: String =>
{
- val result =
httpGetRequest(s"http://$nodeIp:8558/cluster/members";).futureValue(httpCallTimeout)
+ val result =
httpGetRequest(s"http://$nodeIp:7626/cluster/members";).futureValue(httpCallTimeout)
result._1 should ===(200)
result._2 should not be 'empty
diff --git
a/integration-test/aws-api-ec2/src/main/resources/CloudFormation/pekko-cluster.json
b/integration-test/aws-api-ec2/src/main/resources/CloudFormation/pekko-cluster.json
index 33de6af..13bb2d8 100644
---
a/integration-test/aws-api-ec2/src/main/resources/CloudFormation/pekko-cluster.json
+++
b/integration-test/aws-api-ec2/src/main/resources/CloudFormation/pekko-cluster.json
@@ -178,41 +178,41 @@
]
}
},
- "AkkaClusterSecurityGroupIngressForPeers2552": {
+ "AkkaClusterSecurityGroupIngressForPeers7355": {
"Type": "AWS::EC2::SecurityGroupIngress",
"Properties": {
"GroupName": {
"Ref": "AkkaClusterSecurityGroup"
},
"IpProtocol": "tcp",
- "FromPort": 2552,
- "ToPort": 2552,
+ "FromPort": 7355,
+ "ToPort": 7355,
"SourceSecurityGroupName": {
"Ref": "AkkaClusterSecurityGroup"
}
}
},
- "AkkaClusterSecurityGroupIngressForOutsiders8558": {
+ "AkkaClusterSecurityGroupIngressForOutsiders7626": {
"Type": "AWS::EC2::SecurityGroupIngress",
"Properties": {
"GroupName": {
"Ref": "AkkaClusterSecurityGroup"
},
"IpProtocol": "tcp",
- "FromPort": 8558,
- "ToPort": 8558,
+ "FromPort": 7626,
+ "ToPort": 7626,
"CidrIp": {"Ref": "SSHLocation"}
}
},
- "AkkaClusterSecurityGroupIngressForPeers8558": {
+ "AkkaClusterSecurityGroupIngressForPeers7626": {
"Type": "AWS::EC2::SecurityGroupIngress",
"Properties": {
"GroupName": {
"Ref": "AkkaClusterSecurityGroup"
},
"IpProtocol": "tcp",
- "FromPort": 8558,
- "ToPort": 8558,
+ "FromPort": 7626,
+ "ToPort": 7626,
"SourceSecurityGroupName": {
"Ref": "AkkaClusterSecurityGroup"
}
diff --git a/integration-test/aws-api-ecs/README.md
b/integration-test/aws-api-ecs/README.md
index b97c2c3..99cdf70 100644
--- a/integration-test/aws-api-ecs/README.md
+++ b/integration-test/aws-api-ecs/README.md
@@ -69,10 +69,10 @@ just delegates to `aws cloudformation create-stack`):
## Watch it form
The security group that the stack defines and associates with the task
-definition includes a rule to allow public access to port 8558 so that the
+definition includes a rule to allow public access to port 7626 so that the
formation of the cluster can be observed as follows:
-`watch -n 1 -c "curl http://$TASK_INSTANCE_IP:8558/cluster/members/ | python
+`watch -n 1 -c "curl http://$TASK_INSTANCE_IP:7626/cluster/members/ | python
-mjson.tool"`
`$taskInstanceIp` should be replaced with the public IP of any of the five task
@@ -87,10 +87,10 @@ When the cluster has fully formed you should see output
like this:
```
{
- "leader": "pekko.tcp://[email protected]:2552",
+ "leader": "pekko.tcp://[email protected]:7355",
"members": [
{
- "node": "pekko.tcp://[email protected]:2552",
+ "node": "pekko.tcp://[email protected]:7355",
"nodeUid": "-801839214",
"roles": [
"dc-default"
@@ -98,7 +98,7 @@ When the cluster has fully formed you should see output like
this:
"status": "Up"
},
{
- "node": "pekko.tcp://[email protected]:2552",
+ "node": "pekko.tcp://[email protected]:7355",
"nodeUid": "-1965866076",
"roles": [
"dc-default"
@@ -106,7 +106,7 @@ When the cluster has fully formed you should see output
like this:
"status": "Up"
},
{
- "node": "pekko.tcp://[email protected]:2552",
+ "node": "pekko.tcp://[email protected]:7355",
"nodeUid": "1441500118",
"roles": [
"dc-default"
@@ -114,7 +114,7 @@ When the cluster has fully formed you should see output
like this:
"status": "Up"
},
{
- "node": "pekko.tcp://[email protected]:2552",
+ "node": "pekko.tcp://[email protected]:7355",
"nodeUid": "443867006",
"roles": [
"dc-default"
@@ -122,7 +122,7 @@ When the cluster has fully formed you should see output
like this:
"status": "Up"
},
{
- "node": "pekko.tcp://[email protected]:2552",
+ "node": "pekko.tcp://[email protected]:7355",
"nodeUid": "-17061216",
"roles": [
"dc-default"
@@ -130,8 +130,8 @@ When the cluster has fully formed you should see output
like this:
"status": "Up"
}
],
- "oldest": "pekko.tcp://[email protected]:2552",
- "selfNode": "pekko.tcp://[email protected]:2552",
+ "oldest": "pekko.tcp://[email protected]:7355",
+ "selfNode": "pekko.tcp://[email protected]:7355",
"unreachable": []
}
```
diff --git
a/integration-test/aws-api-ecs/cfn-templates/ecs-integration-test-app.yaml
b/integration-test/aws-api-ecs/cfn-templates/ecs-integration-test-app.yaml
index 75a4f4d..e1a7697 100644
--- a/integration-test/aws-api-ecs/cfn-templates/ecs-integration-test-app.yaml
+++ b/integration-test/aws-api-ecs/cfn-templates/ecs-integration-test-app.yaml
@@ -80,28 +80,28 @@ Resources:
GroupDescription: !Sub "${AWS::StackName}-service"
SecurityGroupIngress:
- IpProtocol: "tcp"
- FromPort: 8558
- ToPort: 8558
+ FromPort: 7626
+ ToPort: 7626
CidrIp: "0.0.0.0/0"
- IpProtocol: "tcp"
- FromPort: 8558
- ToPort: 8558
+ FromPort: 7626
+ ToPort: 7626
CidrIpv6: "::/0"
ServiceSecurityGroupPekkoManagementSelfIngress:
Type: AWS::EC2::SecurityGroupIngress
Properties:
GroupId: !GetAtt ServiceSecurityGroup.GroupId
IpProtocol: "tcp"
- FromPort: 8558
- ToPort: 8558
+ FromPort: 7626
+ ToPort: 7626
SourceSecurityGroupId: !GetAtt ServiceSecurityGroup.GroupId
ServiceSecurityGroupAkkaClusterSelfIngress:
Type: AWS::EC2::SecurityGroupIngress
Properties:
GroupId: !GetAtt ServiceSecurityGroup.GroupId
IpProtocol: "tcp"
- FromPort: 2552
- ToPort: 2552
+ FromPort: 7355
+ ToPort: 7355
SourceSecurityGroupId: !GetAtt ServiceSecurityGroup.GroupId
Service:
Type: AWS::ECS::Service
diff --git
a/integration-test/aws-api-ecs/src/main/scala/org/apache/pekko/cluster/bootstrap/EcsApiDemoApp.scala
b/integration-test/aws-api-ecs/src/main/scala/org/apache/pekko/cluster/bootstrap/EcsApiDemoApp.scala
index 63d9776..35e9e8d 100644
---
a/integration-test/aws-api-ecs/src/main/scala/org/apache/pekko/cluster/bootstrap/EcsApiDemoApp.scala
+++
b/integration-test/aws-api-ecs/src/main/scala/org/apache/pekko/cluster/bootstrap/EcsApiDemoApp.scala
@@ -32,7 +32,7 @@ object EcsApiDemoApp {
|pekko {
| actor.provider = "cluster"
| management {
- | cluster.bootstrap.contact-point.fallback-port = 8558
+ | cluster.bootstrap.contact-point.fallback-port = 7626
| http.hostname = "${privateAddress.getHostAddress}"
| }
| discovery.method = aws-api-ecs-async
diff --git a/integration-test/dns-api-mesos/marathon/app.bridge-mode.json
b/integration-test/dns-api-mesos/marathon/app.bridge-mode.json
index c920908..eb4b6b6 100644
--- a/integration-test/dns-api-mesos/marathon/app.bridge-mode.json
+++ b/integration-test/dns-api-mesos/marathon/app.bridge-mode.json
@@ -26,8 +26,8 @@
"name": "remoting"
},
{
- "containerPort": 8558,
- "hostPort": 8558,
+ "containerPort": 7626,
+ "hostPort": 7626,
"servicePort": 10206,
"protocol": "tcp",
"name": "http"
diff --git a/integration-test/dns-api-mesos/src/main/resources/application.conf
b/integration-test/dns-api-mesos/src/main/resources/application.conf
index 4efe7f6..211d236 100644
--- a/integration-test/dns-api-mesos/src/main/resources/application.conf
+++ b/integration-test/dns-api-mesos/src/main/resources/application.conf
@@ -23,11 +23,11 @@ pekko {
# This defines the interface to use.
# InetAddress.getLocalHost.getHostAddress is used not overriden or empty
hostname = ${HOST}
- port = 8558
- port = ${?PORT_8558}
+ port = 7626
+ port = ${?PORT_7626}
bind-hostname = 0.0.0.0
- bind-port = 8558
+ bind-port = 7626
}
cluster.bootstrap {
@@ -61,8 +61,8 @@ pekko {
# Configured how we communicate with the contact point once it is
discovered
contact-point {
# If no port is discovered along with the host/ip of a contact point
this port will be used as fallback
- fallback-port = 8558
- fallback-port = ${?PORT_8558}
+ fallback-port = 7626
+ fallback-port = ${?PORT_7626}
}
}
diff --git a/integration-test/kubernetes-api-java/kubernetes/pekko-cluster.yml
b/integration-test/kubernetes-api-java/kubernetes/pekko-cluster.yml
index 2936490..875012e 100644
--- a/integration-test/kubernetes-api-java/kubernetes/pekko-cluster.yml
+++ b/integration-test/kubernetes-api-java/kubernetes/pekko-cluster.yml
@@ -27,14 +27,14 @@ spec:
imagePullPolicy: Never
livenessProbe:
tcpSocket:
- port: 8558
+ port: 7626
ports:
# akka remoting
- name: remoting
- containerPort: 2552
+ containerPort: 7355
protocol: TCP
# akka-management
- - containerPort: 8558
+ - containerPort: 7626
protocol: TCP
# when contact-point-discovery.port-name is set for cluster
bootstrap,
# the management port must be named accordingly:
diff --git a/integration-test/kubernetes-api-java/pom.xml
b/integration-test/kubernetes-api-java/pom.xml
index 2609ba8..5ec0e9c 100644
--- a/integration-test/kubernetes-api-java/pom.xml
+++ b/integration-test/kubernetes-api-java/pom.xml
@@ -146,8 +146,8 @@
<from>openjdk:8-jre-alpine</from>
<ports>
<port>8080</port>
- <port>8558</port>
- <port>2552</port>
+ <port>7626</port>
+ <port>7355</port>
</ports>
<entryPoint>
<exec>
diff --git a/integration-test/kubernetes-api/build.sbt
b/integration-test/kubernetes-api/build.sbt
index 144a8e7..5842021 100644
--- a/integration-test/kubernetes-api/build.sbt
+++ b/integration-test/kubernetes-api/build.sbt
@@ -10,7 +10,7 @@ dockerCommands :=
case v => Seq(v)
}
-dockerExposedPorts := Seq(8080, 8558, 2552)
+dockerExposedPorts := Seq(8080, 7626, 7355)
dockerBaseImage := "openjdk:8-jre-alpine"
dockerCommands ++= Seq(
diff --git a/integration-test/kubernetes-api/kubernetes/pekko-cluster.yml
b/integration-test/kubernetes-api/kubernetes/pekko-cluster.yml
index 464b058..df1ede2 100644
--- a/integration-test/kubernetes-api/kubernetes/pekko-cluster.yml
+++ b/integration-test/kubernetes-api/kubernetes/pekko-cluster.yml
@@ -39,7 +39,7 @@ spec:
#health
ports:
# akka-management bootstrap
- - containerPort: 8558
+ - containerPort: 7626
protocol: TCP
# when contact-point-discovery.port-name is set for cluster
bootstrap,
# the management port must be named accordingly:
diff --git a/integration-test/kubernetes-dns/build.sbt
b/integration-test/kubernetes-dns/build.sbt
index 4dd0946..b8a958c 100644
--- a/integration-test/kubernetes-dns/build.sbt
+++ b/integration-test/kubernetes-dns/build.sbt
@@ -9,7 +9,7 @@ dockerCommands :=
case v => Seq(v)
}
-dockerExposedPorts := Seq(8080, 8558, 2552)
+dockerExposedPorts := Seq(8080, 7626, 7355)
dockerBaseImage := "openjdk:8-jre-alpine"
dockerCommands ++= Seq(
diff --git a/integration-test/kubernetes-dns/kubernetes/pekko-cluster.yml
b/integration-test/kubernetes-dns/kubernetes/pekko-cluster.yml
index 04d35d7..3dc7e0d 100644
--- a/integration-test/kubernetes-dns/kubernetes/pekko-cluster.yml
+++ b/integration-test/kubernetes-dns/kubernetes/pekko-cluster.yml
@@ -39,11 +39,11 @@ spec:
port: management
#health
ports:
- - containerPort: 8558
+ - containerPort: 7626
# when contact-point-discovery.port-name is set for cluster
bootstrap,
# the management port must be named accordingly:
# name: management
- - containerPort: 2552
+ - containerPort: 7355
name: remoting
env:
# Can be removed once async-dns supports search domains (in Akka
2.5.20)
@@ -69,13 +69,13 @@ metadata:
spec:
ports:
- name: management
- port: 8558
+ port: 7626
protocol: TCP
- targetPort: 8558
+ targetPort: 7626
- name: remoting
- port: 2552
+ port: 7355
protocol: TCP
- targetPort: 2552
+ targetPort: 7355
selector:
app: pekko-bootstrap-demo
clusterIP: None
diff --git
a/integration-test/kubernetes-dns/src/main/resources/application.conf
b/integration-test/kubernetes-dns/src/main/resources/application.conf
index a822e8b..8731890 100644
--- a/integration-test/kubernetes-dns/src/main/resources/application.conf
+++ b/integration-test/kubernetes-dns/src/main/resources/application.conf
@@ -7,7 +7,7 @@ pekko {
}
remote {
netty.tcp {
- port = 2552
+ port = 7355
}
}
}
@@ -21,7 +21,7 @@ pekko.management {
}
http {
- port = 8558
+ port = 7626
bind-hostname = "0.0.0.0"
}
}
diff --git a/integration-test/local/src/main/resources/application.conf
b/integration-test/local/src/main/resources/application.conf
index b674b6a..5d040ac 100644
--- a/integration-test/local/src/main/resources/application.conf
+++ b/integration-test/local/src/main/resources/application.conf
@@ -30,15 +30,15 @@ pekko.discovery {
endpoints = [
{
host = "127.0.0.1"
- port = 8558
+ port = 7626
},
{
host = "127.0.0.2"
- port = 8558
+ port = 7626
},
{
host = "127.0.0.3"
- port = 8558
+ port = 7626
}
]
}
diff --git a/integration-test/marathon-api-docker/README.md
b/integration-test/marathon-api-docker/README.md
index dd632dc..2d44402 100644
--- a/integration-test/marathon-api-docker/README.md
+++ b/integration-test/marathon-api-docker/README.md
@@ -54,7 +54,7 @@ see `marathon/marathon-api-docker-app.json`:
"portMappings": [
...
{
- "containerPort": 8558,
+ "containerPort": 7626,
"hostPort": 0,
"servicePort": 10206,
"protocol": "tcp",
diff --git
a/integration-test/marathon-api-docker/marathon/marathon-api-docker-app.json
b/integration-test/marathon-api-docker/marathon/marathon-api-docker-app.json
index 84c469f..30dbbda 100644
--- a/integration-test/marathon-api-docker/marathon/marathon-api-docker-app.json
+++ b/integration-test/marathon-api-docker/marathon/marathon-api-docker-app.json
@@ -36,7 +36,7 @@
"name": "remoting"
},
{
- "containerPort": 8558,
+ "containerPort": 7626,
"hostPort": 0,
"servicePort": 10206,
"protocol": "tcp",
diff --git
a/integration-test/marathon-api-docker/src/main/resources/application.conf
b/integration-test/marathon-api-docker/src/main/resources/application.conf
index 1108e21..513cc3a 100644
--- a/integration-test/marathon-api-docker/src/main/resources/application.conf
+++ b/integration-test/marathon-api-docker/src/main/resources/application.conf
@@ -42,11 +42,11 @@ pekko {
# This defines the interface to use.
# InetAddress.getLocalHost.getHostAddress is used not overriden or empty
hostname = ${HOST}
- port = 8558
- port = ${?PORT_8558}
+ port = 7626
+ port = ${?PORT_7626}
bind-hostname = 0.0.0.0
- bind-port = 8558
+ bind-port = 7626
}
cluster.bootstrap {
diff --git a/integration-test/marathon-api/src/main/resources/application.conf
b/integration-test/marathon-api/src/main/resources/application.conf
index 4651b42..a849bcd 100644
--- a/integration-test/marathon-api/src/main/resources/application.conf
+++ b/integration-test/marathon-api/src/main/resources/application.conf
@@ -11,7 +11,7 @@ pekko {
management {
http {
- port = 8558
+ port = 7626
}
}
@@ -22,7 +22,7 @@ pekko {
discovery-method = marathon-api
}
contact-point {
- fallback-port = 8558
+ fallback-port = 7626
}
}
}
diff --git
a/management-cluster-bootstrap/src/test/scala/org/apache/pekko/management/cluster/bootstrap/LowestAddressJoinDeciderSpec.scala
b/management-cluster-bootstrap/src/test/scala/org/apache/pekko/management/cluster/bootstrap/LowestAddressJoinDeciderSpec.scala
index 3e15003..6a0f235 100644
---
a/management-cluster-bootstrap/src/test/scala/org/apache/pekko/management/cluster/bootstrap/LowestAddressJoinDeciderSpec.scala
+++
b/management-cluster-bootstrap/src/test/scala/org/apache/pekko/management/cluster/bootstrap/LowestAddressJoinDeciderSpec.scala
@@ -129,10 +129,10 @@ class LowestAddressJoinDeciderSpec extends
JoinDeciderSpec {
new SeedNodesObservation(
now.minusSeconds(1),
contactA,
- Address("pekko", "join-decider-spec-system", "10.0.0.2", 2552),
- Set(Address("pekko", "join-decider-spec-system", "10.0.0.2",
2552)))))
+ Address("pekko", "join-decider-spec-system", "10.0.0.2", 7355),
+ Set(Address("pekko", "join-decider-spec-system", "10.0.0.2",
7355)))))
decider.decide(info).futureValue should ===(
- JoinOtherSeedNodes(Set(Address("pekko", "join-decider-spec-system",
"10.0.0.2", 2552))))
+ JoinOtherSeedNodes(Set(Address("pekko", "join-decider-spec-system",
"10.0.0.2", 7355))))
}
"keep probing when contact points changed within stable-margin" in {
@@ -146,17 +146,17 @@ class LowestAddressJoinDeciderSpec extends
JoinDeciderSpec {
new SeedNodesObservation(
now.minusSeconds(1),
contactA,
- Address("pekko", "join-decider-spec-system", "10.0.0.2", 2552),
+ Address("pekko", "join-decider-spec-system", "10.0.0.2", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactB,
- Address("pekko", "join-decider-spec-system", "b", 2552),
+ Address("pekko", "join-decider-spec-system", "b", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactC,
- Address("pekko", "join-decider-spec-system", "c", 2552),
+ Address("pekko", "join-decider-spec-system", "c", 7355),
Set.empty)))
decider.decide(info).futureValue should ===(KeepProbing)
}
@@ -172,12 +172,12 @@ class LowestAddressJoinDeciderSpec extends
JoinDeciderSpec {
new SeedNodesObservation(
now.minusSeconds(1),
contactA,
- Address("pekko", "join-decider-spec-system", "10.0.0.2", 2552),
+ Address("pekko", "join-decider-spec-system", "10.0.0.2", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactB,
- Address("pekko", "join-decider-spec-system", "b", 2552),
+ Address("pekko", "join-decider-spec-system", "b", 7355),
Set.empty)))
decider.decide(info).futureValue should ===(KeepProbing)
}
@@ -193,12 +193,12 @@ class LowestAddressJoinDeciderSpec extends
JoinDeciderSpec {
new SeedNodesObservation(
now.minusSeconds(1),
contactA,
- Address("pekko", "join-decider-spec-system", "10.0.0.2", 2552),
+ Address("pekko", "join-decider-spec-system", "10.0.0.2", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactB,
- Address("pekko", "join-decider-spec-system", "b", 2552),
+ Address("pekko", "join-decider-spec-system", "b", 7355),
Set.empty))
// << 2 < required-contact-point-nr
)
@@ -218,17 +218,17 @@ class LowestAddressJoinDeciderSpec extends
JoinDeciderSpec {
new SeedNodesObservation(
now.minusSeconds(1),
contactA,
- Address("pekko", "join-decider-spec-system", "10.0.0.2", 2552),
+ Address("pekko", "join-decider-spec-system", "10.0.0.2", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactB,
- Address("pekko", "join-decider-spec-system", "b", 2552),
+ Address("pekko", "join-decider-spec-system", "b", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactC,
- Address("pekko", "join-decider-spec-system", "c", 2552),
+ Address("pekko", "join-decider-spec-system", "c", 7355),
Set.empty)))
decider.decide(info).futureValue should ===(JoinSelf)
}
@@ -256,17 +256,17 @@ class SelfAwareJoinDeciderSpec extends JoinDeciderSpec {
new SeedNodesObservation(
now.minusSeconds(1),
contactA,
- Address("pekko", "join-decider-spec-system-selfaware", "10.0.0.2",
2552),
+ Address("pekko", "join-decider-spec-system-selfaware", "10.0.0.2",
7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactB,
- Address("pekko", "join-decider-spec-system-selfaware", "b", 2552),
+ Address("pekko", "join-decider-spec-system-selfaware", "b", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactC,
- Address("pekko", "join-decider-spec-system-selfaware", "c", 2552),
+ Address("pekko", "join-decider-spec-system-selfaware", "c", 7355),
Set.empty)))
}
@@ -331,17 +331,17 @@ class SelfAwareJoinDeciderIPv6Spec extends
JoinDeciderSpec {
new SeedNodesObservation(
now.minusSeconds(1),
contactIPv6A,
- Address("pekko", "join-decider-spec-system-selfaware-ipv6",
"[240b:c0e0:202:5e2b:b424:2:0:450]", 2552),
+ Address("pekko", "join-decider-spec-system-selfaware-ipv6",
"[240b:c0e0:202:5e2b:b424:2:0:450]", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactIPv6B,
- Address("pekko", "join-decider-spec-system-selfaware-ipv6",
"[240b:c0e0:202:5e2b:b424:2:0:cc4]", 2552),
+ Address("pekko", "join-decider-spec-system-selfaware-ipv6",
"[240b:c0e0:202:5e2b:b424:2:0:cc4]", 7355),
Set.empty),
new SeedNodesObservation(
now.minusSeconds(1),
contactIPv6C,
- Address("pekko", "join-decider-spec-system-selfaware-ipv6", "c",
2552),
+ Address("pekko", "join-decider-spec-system-selfaware-ipv6", "c",
7355),
Set.empty)))
}
diff --git
a/management-cluster-bootstrap/src/test/scala/org/apache/pekko/management/cluster/bootstrap/internal/BootstrapCoordinatorSpec.scala
b/management-cluster-bootstrap/src/test/scala/org/apache/pekko/management/cluster/bootstrap/internal/BootstrapCoordinatorSpec.scala
index 53f1222..bc9c2d0 100644
---
a/management-cluster-bootstrap/src/test/scala/org/apache/pekko/management/cluster/bootstrap/internal/BootstrapCoordinatorSpec.scala
+++
b/management-cluster-bootstrap/src/test/scala/org/apache/pekko/management/cluster/bootstrap/internal/BootstrapCoordinatorSpec.scala
@@ -33,7 +33,7 @@ import org.scalatest.wordspec.AnyWordSpec
class BootstrapCoordinatorSpec extends AnyWordSpec with Matchers with
BeforeAndAfterAll with Eventually {
val serviceName = "bootstrap-coordinator-test-service"
- val selfUri = Uri("http://localhost:8558/";)
+ val selfUri = Uri("http://localhost:7626/";)
val system = ActorSystem(
"test",
ConfigFactory.parseString(s"""
@@ -60,10 +60,10 @@ class BootstrapCoordinatorSpec extends AnyWordSpec with
Matchers with BeforeAndA
Resolved(
serviceName,
List(
- ResolvedTarget("host1", Some(2552), None),
- ResolvedTarget("host1", Some(8558), None),
- ResolvedTarget("host2", Some(2552), None),
- ResolvedTarget("host2", Some(8558), None)))))
+ ResolvedTarget("host1", Some(7355), None),
+ ResolvedTarget("host1", Some(7626), None),
+ ResolvedTarget("host2", Some(7355), None),
+ ResolvedTarget("host2", Some(7626), None)))))
val targets = new AtomicReference[List[ResolvedTarget]](Nil)
val coordinator = system.actorOf(
@@ -83,7 +83,7 @@ class BootstrapCoordinatorSpec extends AnyWordSpec with
Matchers with BeforeAndA
targetsToCheck.length should be >= 2
targetsToCheck.map(_.host) should contain("host1")
targetsToCheck.map(_.host) should contain("host2")
- targetsToCheck.flatMap(_.port).toSet should be(Set(8558))
+ targetsToCheck.flatMap(_.port).toSet should be(Set(7626))
}
}
@@ -132,7 +132,7 @@ class BootstrapCoordinatorSpec extends AnyWordSpec with
Matchers with BeforeAndA
BootstrapCoordinator.selectHosts(
Lookup.create("service").withPortName("cats"),
- 8558,
+ 7626,
filterOnFallbackPort = true,
beforeFiltering) shouldEqual beforeFiltering
}
@@ -140,15 +140,15 @@ class BootstrapCoordinatorSpec extends AnyWordSpec with
Matchers with BeforeAndA
// For example when using DNS A-record-based discovery in K8s
"filter when port-name is not set" in {
val beforeFiltering = List(
- ResolvedTarget("host1", Some(8558), None),
+ ResolvedTarget("host1", Some(7626), None),
ResolvedTarget("host1", Some(2), None),
- ResolvedTarget("host2", Some(8558), None),
+ ResolvedTarget("host2", Some(7626), None),
ResolvedTarget("host2", Some(4), None))
- BootstrapCoordinator.selectHosts(Lookup.create("service"), 8558,
filterOnFallbackPort = true,
+ BootstrapCoordinator.selectHosts(Lookup.create("service"), 7626,
filterOnFallbackPort = true,
beforeFiltering) shouldEqual List(
- ResolvedTarget("host1", Some(8558), None),
- ResolvedTarget("host2", Some(8558), None))
+ ResolvedTarget("host1", Some(7626), None),
+ ResolvedTarget("host2", Some(7626), None))
}
// For example when using ECS service discovery
@@ -159,19 +159,19 @@ class BootstrapCoordinatorSpec extends AnyWordSpec with
Matchers with BeforeAndA
ResolvedTarget("host2", Some(3), None),
ResolvedTarget("host2", Some(4), None))
- BootstrapCoordinator.selectHosts(Lookup.create("service"), 8558,
filterOnFallbackPort = false,
+ BootstrapCoordinator.selectHosts(Lookup.create("service"), 7626,
filterOnFallbackPort = false,
beforeFiltering) shouldEqual beforeFiltering
}
"not filter if there is a single target per host" in {
val beforeFiltering = List(
- ResolvedTarget("host1", Some(8558), None),
+ ResolvedTarget("host1", Some(7626), None),
ResolvedTarget("host2", Some(2), None),
- ResolvedTarget("host3", Some(8558), None),
+ ResolvedTarget("host3", Some(7626), None),
ResolvedTarget("host4", Some(4), None))
BootstrapCoordinator
- .selectHosts(Lookup.create("service"), 8558, filterOnFallbackPort =
true, beforeFiltering)
+ .selectHosts(Lookup.create("service"), 7626, filterOnFallbackPort =
true, beforeFiltering)
.toSet shouldEqual beforeFiltering.toSet
}
}
diff --git a/management/src/main/resources/reference.conf
b/management/src/main/resources/reference.conf
index 29728d0..12f8621 100644
--- a/management/src/main/resources/reference.conf
+++ b/management/src/main/resources/reference.conf
@@ -16,7 +16,7 @@ pekko.management {
# The port where the HTTP Server for Http Cluster Management will be bound.
# The value will need to be from 0 to 65535.
- port = 8558 # port pun, it "complements" 2552 which is often used for
Pekko remoting
+ port = 7626 # PMAN (Pekko MANagement) on a telephone keypad (ITU E.161)
# Use this setting to bind a network interface to a different hostname or
ip
# than the HTTP Server for Http Cluster Management.
diff --git a/management/src/test/resources/reference.conf
b/management/src/test/resources/reference.conf
index 062858e..9863ae0 100644
--- a/management/src/test/resources/reference.conf
+++ b/management/src/test/resources/reference.conf
@@ -5,7 +5,7 @@ pekko {
remote {
netty.tcp {
hostname = "127.0.0.1"
- port = 2552
+ port = 7355
}
}
diff --git
a/management/src/test/scala/org/apache/pekko/management/PekkoManagementHttpEndpointSpec.scala
b/management/src/test/scala/org/apache/pekko/management/PekkoManagementHttpEndpointSpec.scala
index 2a31bf7..a556409 100644
---
a/management/src/test/scala/org/apache/pekko/management/PekkoManagementHttpEndpointSpec.scala
+++
b/management/src/test/scala/org/apache/pekko/management/PekkoManagementHttpEndpointSpec.scala
@@ -71,7 +71,7 @@ class PekkoManagementHttpEndpointSpec extends AnyWordSpecLike
with Matchers {
s"""
//#management-host-port
pekko.management.http.hostname = "127.0.0.1"
- pekko.management.http.port = 8558
+ pekko.management.http.port = 7626
//#management-host-port
pekko.management.http.port = $httpPort
pekko.management.http.routes {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
