leontoetenel/alert_streamer

alert_streamer

alert_streamer is een Python-service die alerts consumeert via de Kafka REST API, deze verrijkt met Dynatrace entity ID’s uit Redis/Valkey, en ze doorstuurt als CUSTOM_ALERT events naar de Dynatrace Events API v2.

Features

• Kafka REST consumer voor alert-ingestie
• Redis/Valkey cache lookup voor Dynatrace entityId’s
• Dynatrace Events API v2 integratie
• Periodieke heartbeat-logs elke 60s
• TLS-modus: safe (certificaten gevalideerd) of unsafe (equivalent van curl -k)
• Klaar voor OpenShift en Docker (non-root, arbitrary UID-proof)

Voorbeeld JSON alert

json
{
  "type": "HOST | PROCESS_GROUP | PROCESS_GROUP_INSTANCE",
  "name": "Naam van de host of (process group / instance)",
  "timestamp": "2025-10-15T11:15:00Z",
  "alert_name": "Korte titel van de alert",
  "message": "Uitgebreide beschrijving van het probleem",
  "severity": "info | warning | error | critical",
  "link_to_source": "http://url.naar/bron/log/of/dashboard",
  "timeout": 600
}

Environment variables

Local run (Docker)

bash
docker run --rm \
  -e KAFKA_BOOTSTRAP=kafka:9092 \
  -e KAFKA_TOPIC=alerts.dynatrace \
  -e VALKEY_HOST=valkey \
  -e DT_API_URL=https://<tenant>.live.dynatrace.com \
  -e DT_API_TOKEN=*** \
  leontoetenel/alert_streamer:latest

OpenShift / Kubernetes deployment

ConfigMap

configmap
apiVersion: v1
kind: ConfigMap
metadata:
  name: alert-streamer-config
data:
  DT_API_URL: "https://<tenant>.live.dynatrace.com"
  KAFKA_REST_URL: "https://kafka-rest.mycompany.com"
  KAFKA_TOPIC: "alerts.dynatrace"
  VALKEY_HOST: "valkey"
  SECURITY_MODE: "safe"

Secret

secret
apiVersion: v1
kind: Secret
metadata:
  name: alert-streamer-secrets
type: Opaque
stringData:
  DT_API_URL: "https://<tenant>.live.dynatrace.com"
  DT_API_TOKEN: "<your-api-token>"

Deployment

Deployment
apiVersion: apps/v1
kind: Deployment
metadata:
  name: alert-streamer
spec:
  replicas: 1
  selector:
    matchLabels:
      app: alert-streamer
  template:
    metadata:
      labels:
        app: alert-streamer
    spec:
      containers:
      - name: alert-streamer
        image: docker.io/leontoetenel/alert_streamer:latest
        imagePullPolicy: IfNotPresent
        envFrom:
        - configMapRef:
            name: alert-streamer-config
        - secretRef:
            name: alert-streamer-secrets
        resources:
          requests:
            cpu: "100m"
            memory: "128Mi"
          limits:
            cpu: "500m"
            memory: "512Mi"
        securityContext:
          allowPrivilegeEscalation: false
          runAsNonRoot: true
          seccompProfile:
            type: RuntimeDefault
      securityContext:
        fsGroup: 0