Skip to content

Commit

Permalink
Use pinned dispatcher for kafka consumer in order to have one thread
Browse files Browse the repository at this point in the history
per consumer

* This should reduce latency for cases where a lot of kafka consumers are
  running and could potentially block the thread to long for other consumers

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
  • Loading branch information
Yannic92 authored and thjaeckle committed Nov 3, 2021
1 parent 40b741a commit 4caa80f
Showing 1 changed file with 1 addition and 7 deletions.
8 changes: 1 addition & 7 deletions connectivity/service/src/main/resources/connectivity.conf
Expand Up @@ -844,14 +844,8 @@ http-push-connection-dispatcher {
}

kafka-consumer-dispatcher {
type = "Dispatcher"
type = PinnedDispatcher
executor = "thread-pool-executor"
thread-pool-executor {
keep-alive-time = 60s
fixed-pool-size = off
max-pool-size-max = 256
max-pool-size-max = ${?KAFKA_CONNECTION_DISPATCHER_POOL_SIZE_MAX}
}
}

kafka-producer-dispatcher {
Expand Down

0 comments on commit 4caa80f

Please sign in to comment.