Story Crater Bot
1c02e2b831
- Kafka 3-broker cluster (RF=3, min-ISR=2) - kmsvc SQS-like API on Kafka - Redis dedup (standalone, can extend to HA) - Temporal workflow orchestration (Cassandra backend)
39 lines
910 B
YAML
39 lines
910 B
YAML
# Example Queues for "production" Temporal namespace
|
|
# When applied, queue-operator creates 1 TemporalWorker (worker-production)
|
|
# that processes ALL queues in the "production" namespace
|
|
---
|
|
apiVersion: kmsvc.io/v1
|
|
kind: Queue
|
|
metadata:
|
|
name: story-crater-tasks
|
|
namespace: sqs
|
|
labels:
|
|
temporal.io/namespace: "production"
|
|
spec:
|
|
fifoQueue: false
|
|
visibilityTimeoutSeconds: 30
|
|
messageRetentionPeriodSeconds: 345600
|
|
maxReceiveCount: 5
|
|
partitionsPerShard: 6
|
|
minShards: 1
|
|
maxShards: 8
|
|
shardSplitThresholdBytesPerSec: 5242880
|
|
|
|
---
|
|
apiVersion: kmsvc.io/v1
|
|
kind: Queue
|
|
metadata:
|
|
name: story-crater-notifications
|
|
namespace: sqs
|
|
labels:
|
|
temporal.io/namespace: "production"
|
|
spec:
|
|
fifoQueue: false
|
|
visibilityTimeoutSeconds: 60
|
|
messageRetentionPeriodSeconds: 345600
|
|
maxReceiveCount: 3
|
|
partitionsPerShard: 3
|
|
minShards: 1
|
|
maxShards: 4
|
|
shardSplitThresholdBytesPerSec: 2621440
|