bwmcadams commented on a change in pull request #2956: Introduce separate Akka
dispatchers for CouchDB and Kafka Clients
URL:
https://github.com/apache/incubator-openwhisk/pull/2956#discussion_r152354263
##########
File path: common/scala/src/main/resources/reference.conf
##########
@@ -3,4 +3,36 @@ whisk.spi{
MessagingProvider = whisk.connector.kafka.KafkaMessagingProvider
ContainerFactoryProvider =
whisk.core.containerpool.docker.DockerContainerFactoryProvider
LogStoreProvider = whisk.core.containerpool.logging.DockerLogStoreProvider
-}
\ No newline at end of file
+}
+
+dispatchers {
+# Custom dispatcher for CouchDB Client. Tune as needed.
+ couch-dispatcher {
+ type = Dispatcher
+ executor = "fork-join-executor"
+
+ fork-join-executor {
+ # Min number of threads to cap factor-based parallelism number to
+ parallelism-min = 2
+ # Parallelism (threads) ... ceil(available processors * factor)
+ parallelism-factor = 2.0
+ # Max number of threads to cap factor-based parallelism number to
+ parallelism-max = 10
+ }
+ }
+
+# Custom dispatcher for Kafka client. Tune as needed.
+ kafka-dispatcher {
+ type = Dispatcher
+ executor = "fork-join-executor"
+
+ fork-join-executor {
+ # Min number of threads to cap factor-based parallelism number to
+ parallelism-min = 2
+ # Parallelism (threads) ... ceil(available processors * factor)
+ parallelism-factor = 2.0
+ # Max number of threads to cap factor-based parallelism number to
+ parallelism-max = 10
+ }
+ }
Review comment:
er, yeah. I think I copied this from docs; it looks like the default for
Akka's default dispatchers is 64. I'll move it to that and we can always tweak
specifically later.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
