Skip to content

Instantly share code, notes, and snippets.

package sample.stream
import akka.{Done, NotUsed}
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._
import scala.concurrent.Future
object SimpleStreamExample {
package sample.stream
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._
import scala.concurrent.Future
object SimpleStreamExample {
akka.cluster.split-brain-resolver.keep-referee {
# referee address on the form of "akka.tcp://system@hostname:port"
address = ""
down-all-if-less-than-nodes = 1
}
akka.cluster.split-brain-resolver.active-strategy=keep-referee
akka.cluster.split-brain-resolver.keep-oldest {
# Enable downing of the oldest node when it is partitioned from all other nodes
down-if-alone = on
role = ""
}
akka.cluster.split-brain-resolver.active-strategy=keep-oldest
akka.cluster.split-brain-resolver.keep-majority {
role = ""
}
akka.cluster.split-brain-resolver.active-strategy=keep-majority
akka.cluster.split-brain-resolver.static-quorum {
quorum-size = undefined
role = ""
}
akka.cluster.split-brain-resolver.active-strategy=static-quorum