Reaktif Akış Talep-Güdümlü (Backpressure) Akış İşlemcisi

resource "aws_ecs_task_definition" "reactive_service" {
  family                   = "tinycto-reactive-pipeline"
  requires_compatibilities = ["FARGATE"]
  network_mode             = "awsvpc"
  cpu                      = "2048"
  memory                   = "4096"
}

apiVersion: apps/v1
kind: Deployment
metadata:
  name: reactive-stream-worker
spec:
  replicas: 4
  template:
    spec:
      containers:
        - name: worker
          image: tinycto/reactive-worker:v2.0
          resources:
            limits:
              memory: 2Gi
            requests:
              memory: 1Gi

// Reactive Streams Pull Contract:
// Subscriber explicitly demands only what it can safely process
Flux.from(kafkaReceiver.receive())
    .limitRate(100) // Prefetches 100 items, sends request(75) when 75% consumed
    .flatMap(event -> processAsync(event), 32)
    .subscribe();