Kafka: 4. GitHub Actions

Esta documentación forma parte de la guía GitHub Actions y GitLab CI. Consulte la guía completa aquí: Inicie un servicio real de Kafka desde su pipeline de GitHub Actions o GitLab CI, ejecute sus pruebas sobre él y elimínelo automáticamente.

👋 ¡Bienvenido a la documentación de Stackhero!

Stackhero le ofrece un entorno de Kafka en la nube totalmente gestionado, disponible en cuestión de minutos. Esto es lo que puede esperar:

  • Sin límites en el tamaño o la transferencia de mensajes: escale sus datos sin preocuparse por restricciones.
  • Actualizaciones sencillas y con un solo clic para mantener su plataforma siempre al día, sin interrupciones ni tareas manuales.
  • Alto rendimiento constante y seguridad robusta en su propia infraestructura privada y dedicada.

Si busca acelerar sus proyectos y reducir la carga operativa, Stackhero le ofrece hosting de Kafka en la nube para ayudarle. Puede tener un clúster listo para producción en unos 5 minutos.

Para empezar, guarde el siguiente contenido como .github/workflows/ci.yml. A partir de ahora, cada push y pull request ejecutará pruebas contra una instancia real de Kafka.

name: CI con Kafka

on: [push, pull_request]

jobs:
  test:
    runs-on: ubuntu-latest
    env:
      STACKHERO_TOKEN: ${{ secrets.STACKHERO_TOKEN }}
      STACK_NAME: ci-kafka-${{ github.run_id }}-${{ github.run_attempt }}
      INSTANCE: "10G"   # Modifique si es necesario (ver paso 3)
      REGION: europe
    steps:
      - uses: actions/checkout@v4

      - name: Instalar Stackhero CLI y el cliente
        run: |
          curl -fsSL https://www.stackhero.io/install.sh | sh
          apt-get update && apt-get install -y --no-install-recommends jq curl netcat-openbsd

      - name: Crear el servicio Kafka
        run: |
          set -euo pipefail
          STACK_ID=$(stackhero --format=script stack-create --name="$STACK_NAME")
          echo "STACK_ID=$STACK_ID" >> "$GITHUB_ENV"
          SERVICE_ID=$(stackhero --format=script service-add \
            --stack="$STACK_ID" \
            --service-store="kafka" \
            --instance="$INSTANCE" \
            --region="$REGION")
          echo "SERVICE_ID=$SERVICE_ID" >> "$GITHUB_ENV"
          stackhero service-wait-for --service="$SERVICE_ID"

      - name: Ejecutar pruebas sobre Kafka
        run: |
          set -euo pipefail
          config=$(stackhero service-configuration-get --service="$SERVICE_ID" --format=json)
          host=$(echo "$config" | jq -r '.configuration.domain')
          # Open a TCP connection to the broker port.
          nc -z -w 5 "$host" 9092
          echo "✅ Kafka es accesible desde CI."
          # Puede ejecutar su propia batería de pruebas aquí usando las credenciales anteriores ...

      - name: Eliminación (siempre, incluso en caso de fallo)
        if: always()
        run: |
          if [ -n "${SERVICE_ID:-}" ]; then
            stackhero service-delete --service="$SERVICE_ID" --confirm
            stackhero service-wait-for --service="$SERVICE_ID"
          fi
          if [ -n "${STACK_ID:-}" ]; then
            stackhero stack-delete --stack="$STACK_ID" --confirm
          fi

El paso de eliminación está configurado con if: always() para que se ejecute siempre, asegurando que su instancia de Kafka se borre y no se le facture por recursos no utilizados.