diff --git a/akka-docs/rst/java/distributed-pub-sub.rst b/akka-docs/rst/java/distributed-pub-sub.rst index 473d203cf2..020f634b55 100644 --- a/akka-docs/rst/java/distributed-pub-sub.rst +++ b/akka-docs/rst/java/distributed-pub-sub.rst @@ -179,6 +179,15 @@ and then it takes a while for it to be populated. akka.extensions = ["akka.cluster.pubsub.DistributedPubSub"] +Delivery Guarantee +------------------ + +As in :ref:`message-general-rules` of Akka, message delivery guarantee in distributed pub sub modes is **at-most-once delivery**. +In other words, messages can be lost over the wire. + +If you are looking for at-least-once delivery guarantee, we recommend `Kafka Akka Streams integration `_. + + Dependencies ------------ diff --git a/akka-docs/rst/scala/distributed-pub-sub.rst b/akka-docs/rst/scala/distributed-pub-sub.rst index 9dcdd52217..1df22e831e 100644 --- a/akka-docs/rst/scala/distributed-pub-sub.rst +++ b/akka-docs/rst/scala/distributed-pub-sub.rst @@ -48,7 +48,7 @@ Actors are registered to a named topic. This enables many subscribers on each no The message will be delivered to all subscribers of the topic. For efficiency the message is sent over the wire only once per node (that has a matching topic), -and then delivered to all subscribers of the local topic representation. +and then delivered to all subscribers of the local topic representation. (See more in ) You register actors to the local mediator with ``DistributedPubSubMediator.Subscribe``. Successful ``Subscribe`` and ``Unsubscribe`` is acknowledged with @@ -182,6 +182,15 @@ and then it takes a while for it to be populated. akka.extensions = ["akka.cluster.pubsub.DistributedPubSub"] + +Delivery Guarantee +------------------ + +As in :ref:`message-general-rules` of Akka, message delivery guarantee in distributed pub sub modes is **at-most-once delivery**. +In other words, messages can be lost over the wire. + +If you are looking for at-least-once delivery guarantee, we recommend `Kafka Akka Streams integration `_. + Dependencies ------------ @@ -198,3 +207,4 @@ maven:: akka-cluster-tools_@binVersion@ @version@ + diff --git a/akka-kernel/src/main/dist/bin/akka-cluster b/akka-kernel/src/main/dist/bin/akka-cluster index 1a34a614ef..b2e29c86b2 100755 --- a/akka-kernel/src/main/dist/bin/akka-cluster +++ b/akka-kernel/src/main/dist/bin/akka-cluster @@ -103,7 +103,6 @@ case "$1" in ensureNodeIsRunningAndAvailable - echo "Querying cluster status" get ClusterStatus ;;