-
Notifications
You must be signed in to change notification settings - Fork 219
/
test.conf
executable file
·131 lines (109 loc) · 3.14 KB
/
test.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
ditto {
mapping-strategy.implementation = "org.eclipse.ditto.services.models.thingsearch.ThingSearchMappingStrategies"
cluster-downing.role = "things-search"
mongodb {
uri = "mongodb://localhost:27017/test"
}
things-search {
query {
mongodb.timeout = 5s
}
}
}
akka {
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = "WARNING"
logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
# for log messages during the actor system is starting up and shutting down:
stdout-loglevel = "WARNING"
log-config-on-start = off
actor {
# do not restart actors if they crash
guardian-supervisor-strategy = "akka.actor.StoppingSupervisorStrategy"
provider = "akka.cluster.ClusterActorRefProvider"
# this is only intended for testing.
serialize-messages = off
serialize-creators = off
debug {
lifecycle = on
}
default-dispatcher {
fork-join-executor {
parallelism-min = 4
parallelism-factor = 3.0
parallelism-max = 32
parallelism-max = ${?DEFAULT_DISPATCHER_PARALLELISM_MAX}
}
}
serializers {
json = "org.eclipse.ditto.services.utils.cluster.JsonJsonifiableSerializer"
}
serialization-bindings {
# Serialize Jsonifiable events with custom JSON serializer:
"org.eclipse.ditto.model.base.json.Jsonifiable" = json
"org.eclipse.ditto.model.base.exceptions.DittoRuntimeException" = json
}
}
extensions = [
"akka.cluster.pubsub.DistributedPubSub"
]
remote {
log-remote-lifecycle-events = on
artery {
enabled = on
transport = tcp
}
artery.canonical {
# InetAddress.getLocalHost.getHostAddress is used if empty
hostname = "127.0.0.1"
hostname = ${?REMOTE_HOSTNAME}
port = 0
port = ${?REMOTE_PORT}
}
artery.bind {
hostname = ${?BIND_HOSTNAME}
port = ${?BIND_REMOTE_PORT}
}
}
cluster {
# Disable legacy metrics in akka-cluster.
metrics.enabled = off
# enable weakly up feature to allow members to join even if some members are unreachable
allow-weakly-up-members = on
# required for akka-management-cluster-bootstrap (to be more robust):
shutdown-after-unsuccessful-join-seed-nodes = 40s
sharding {
state-store-mode = ddata
use-dispatcher = "sharding-dispatcher"
role = "things-search"
}
roles = [
"things-search"
]
}
}
sharding-dispatcher {
type = Dispatcher
executor = "fork-join-executor"
fork-join-executor {
parallelism-min = 4
parallelism-factor = 3.0
parallelism-max = 32
parallelism-max = ${?DEFAULT_DISPATCHER_PARALLELISM_MAX}
}
throughput = 5 # default is 5
}
blocked-namespaces-dispatcher {
type = Dispatcher
executor = "fork-join-executor"
fork-join-executor {
# Min number of threads to cap factor-based parallelism number to
parallelism-min = 4
# Parallelism (threads) ... ceil(available processors * factor)
parallelism-factor = 3.0
# Max number of threads to cap factor-based parallelism number to
parallelism-max = 32
parallelism-max = ${?DEFAULT_DISPATCHER_PARALLELISM_MAX}
}
throughput = 5
}