summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2023-07-06 20:48:26 +0200
committerValery Piashchynski <[email protected]>2023-07-06 20:48:26 +0200
commitf90d1f0770de7be7bd3835fa9309914c3f85a2b0 (patch)
treec48c31c53806b3e077df458dc980b727d83deed6
parentac11064d7bdd0e191e9da77ace6257ee0f8287dd (diff)
chore: update `.rr.yaml`, add the old JOBS option - timeoutv2023.2.0
Signed-off-by: Valery Piashchynski <[email protected]>
-rw-r--r--.rr.yaml7
-rw-r--r--schemas/config/3.0.schema.json7
2 files changed, 12 insertions, 2 deletions
diff --git a/.rr.yaml b/.rr.yaml
index d815cdb0..9403329c 100644
--- a/.rr.yaml
+++ b/.rr.yaml
@@ -1268,9 +1268,14 @@ kafka:
jobs:
# Number of threads which will try to obtain the job from the priority queue
#
- # Default: number of the logical CPU cores
+ # Default: number of the workers + 1
num_pollers: 32
+ # Push operation timeout in seconds
+ #
+ # Default: 60
+ timeout: 60
+
# Size of the internal priority queue
#
# Default: 1_000_000
diff --git a/schemas/config/3.0.schema.json b/schemas/config/3.0.schema.json
index bba1e50a..a807cdef 100644
--- a/schemas/config/3.0.schema.json
+++ b/schemas/config/3.0.schema.json
@@ -1416,13 +1416,18 @@
"type": "object",
"properties": {
"num_pollers": {
- "description": "Number of threads which will try to obtain the job from the priority queue. Default is the number of the logical CPU cores",
+ "description": "Number of threads which will try to obtain the job from the priority queue. Default is the number of workers+1",
"type": "integer",
"examples": [
10,
32
]
},
+ "timeout": {
+ "description": "JOBS Push operation timeout in seconds",
+ "type": "integer",
+ "default": 60
+ },
"pipeline_size": {
"description": "Size of the internal priority queue, if the internal PQ reach the max number of elements, the Push operation will be blocked",
"type": "integer",