# Создано: 2026-04-06
# Deployment iot-kafka-consumer — читает IoT телеметрию из Kafka → пишет в IoT Postgres.
#
# Consumer group "iot-pg-consumer" — можно масштабировать горизонтально без дублирования.
# Offset коммитится ТОЛЬКО после успешной записи в Postgres (at-least-once гарантия).
#
# Применение: kubectl apply -f deployments/k8s/iot-kafka-consumer.yaml

---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: iot-kafka-consumer
  namespace: sless
  labels:
    app: iot-kafka-consumer
spec:
  replicas: 1
  selector:
    matchLabels:
      app: iot-kafka-consumer
  template:
    metadata:
      labels:
        app: iot-kafka-consumer
    spec:
      containers:
        - name: kafka-consumer
          # Тот же образ что и оператор — все IoT бинари в одном образе.
          image: pearlharbor.registryk8s.services.ngcloud.ru/naeel/sless-operator:v0.1.69
          imagePullPolicy: Always
          command: ["/iot-kafka-consumer"]
          env:
            - name: KAFKA_BROKERS
              value: "kafka.sless.svc.cluster.local:9092"
          envFrom:
            # IOT_PG_DSN — master DSN для IoT Postgres (per-tenant DB)
            - secretRef:
                name: iot-postgres-secret
          resources:
            requests:
              memory: "32Mi"
              cpu: "25m"
            limits:
              memory: "64Mi"
              cpu: "100m"
      imagePullSecrets:
        - name: sless-registry-auth