@@ -1329,11 +1329,31 @@ http-push-connection-dispatcher {
1329
1329
# This executor is meant to be allowed to grow quite big as its limited by the max parallelism of each http connection client.
1330
1330
# Limit this parallelism here additionally could lead to confusing results regarding througput of some http connections.
1331
1331
# The core-pool-size-min remains unchanged so its quite small (8). Unused threads will expire after 60s.
1332
- core-pool-size-factor = 2147483647
1333
- core-pool-size-factor = ${?HTTP_PUSH_CORE_POOL_SIZE_FACTOR}
1334
1332
1335
- core-pool-size-max = 2147483647
1336
- core-pool-size-max = ${?HTTP_PUSH_CORE_POOL_SIZE_MAX}
1333
+ thread-pool-executor {
1334
+ # The core-pool-size-factor is used to determine corePoolSize of the
1335
+ # ThreadPoolExecutor using the following formula:
1336
+ # ceil(available processors * factor).
1337
+ # Resulting size is then bounded by the core-pool-size-min and
1338
+ # core-pool-size-max values.
1339
+ # Increasing can help aleviate errors of type "Dropped message as result of backpressure strategy!" during high load.
1340
+ core-pool-size-factor = 4
1341
+ core-pool-size-factor = ${?HTTP_PUSH_CORE_POOL_SIZE_FACTOR}
1342
+ # Max number of threads to cap factor-based corePoolSize number to
1343
+ core-pool-size-max = 64
1344
+ core-pool-size-max = ${?HTTP_PUSH_CORE_POOL_SIZE_MAX}
1345
+ # Minimum number of threads to cap factor-based maximumPoolSize number to
1346
+ max-pool-size-min= 64
1347
+ max-pool-size-min= ${?HTTP_PUSH_POOL_SIZE_MAX}
1348
+ # Max number of threads to cap factor-based maximumPoolSize number to
1349
+ max-pool-size-max = 512
1350
+ max-pool-size-max= ${?HTTP_PUSH_POOL_SIZE_MAX}
1351
+
1352
+ # Allow core threads to time out
1353
+ allow-core-timeout = on
1354
+ # Keep alive time for threads
1355
+ keep-alive-time = 60s
1356
+ }
1337
1357
}
1338
1358
1339
1359
kafka-consumer-dispatcher {
0 commit comments