Kendi Kendini İyileştiren DLQ & Otomatik Yeniden Oynatma Hattı

resource "aws_sns_topic" "dlq_alerts" {
  name = "tinycto-dlq-critical-alarms"
}

resource "aws_cloudwatch_metric_alarm" "dlq_non_empty" {
  alarm_name          = "kafka-dlq-messages-detected"
  comparison_operator = "GreaterThanThreshold"
  evaluation_periods  = 1
  metric_name         = "MessagesIn"
  namespace           = "AWS/Kafka"
  period              = 60
  statistic           = "Sum"
  threshold           = 0
  alarm_actions       = [aws_sns_topic.dlq_alerts.arn]
}

apiVersion: apps/v1
kind: Deployment
metadata:
  name: dlq-replay-service
spec:
  replicas: 2
  template:
    spec:
      containers:
        - name: replayer
          image: tinycto/dlq-replayer:v1.2
          env:
            - name: DLQ_TOPIC
              value: "order-events.DLQ"
            - name: TARGET_TOPIC
              value: "order-events"

max.poll.interval.ms=300000
enable.auto.commit=false
auto.offset.reset=earliest
# Custom DLQ Error Header Contract:
# x-exception-fqcn: "com.tinycto.InvalidOrderSchemaException"
# x-original-topic: "order-events"
# x-original-partition: "4"
# x-original-offset: "1092831"