Skip to content

Commit 5e5e680

Browse files
chore(eco): Adds limited taskworker topic + DLQ topic for Control tasks (#439)
1 parent e491921 commit 5e5e680

File tree

3 files changed

+41
-0
lines changed

3 files changed

+41
-0
lines changed

CODEOWNERS

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,8 @@
8686
/topics/taskworker-buffer-dlq.yaml @getsentry/taskbroker
8787
/topics/taskworker-control.yaml @getsentry/taskbroker
8888
/topics/taskworker-control-dlq.yaml @getsentry/taskbroker
89+
/topics/taskworker-control-limited.yaml @getsentry/taskbroker
90+
/topics/taskworker-control-limited-dlq.yaml @getsentry/taskbroker
8991
/topics/taskworker-ingest.yaml @getsentry/taskbroker
9092
/topics/taskworker-ingest-dlq.yaml @getsentry/taskbroker
9193
/topics/taskworker-ingest-errors.yaml @getsentry/taskbroker
Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
pipeline: taskworker
2+
description: |
3+
DLQ for taskworker-control-limited
4+
services:
5+
producers:
6+
- getsentry/taskbroker
7+
consumers:
8+
- getsentry/taskbroker
9+
schemas:
10+
- version: 1
11+
compatibility_mode: none
12+
type: protobuf
13+
resource: sentry_protos.sentry.v1.taskworker_pb2.TaskActivation
14+
examples:
15+
- taskworker/1/
16+
topic_creation_config:
17+
compression.type: lz4
18+
retention.ms: "604800000" # 7 days
19+
max.message.bytes: "10000000"
Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
pipeline: taskworker
2+
description: |
3+
Taskworker tasks to be executed, with limited resources
4+
services:
5+
producers:
6+
- getsentry/sentry
7+
consumers:
8+
- getsentry/taskbroker
9+
schemas:
10+
- version: 1
11+
compatibility_mode: none
12+
type: protobuf
13+
resource: sentry_protos.sentry.v1.taskworker_pb2.TaskActivation
14+
examples:
15+
- taskworker/1/
16+
topic_creation_config:
17+
compression.type: lz4
18+
message.timestamp.type: LogAppendTime
19+
max.message.bytes: "10000000"
20+
retention.ms: "86400000"

0 commit comments

Comments
 (0)