Kafka: 2. El script de ciclo de vida

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.

A continuación, tiene un ejemplo completo de script que gestiona todo el ciclo de vida del servicio. Demuestra lo sencillo que es el proceso, con solo unos pocos comandos. Puede copiar el YAML listo para su plataforma desde las secciones siguientes.

#!/bin/bash
set -euo pipefail

# STACKHERO_TOKEN lo proporciona el secreto de CI, la CLI lo detecta automáticamente.

stackName="ci-kafka-$$"          # Nombre de stack único para cada ejecución
serviceStore="kafka"             # El store del servicio Kafka
instance="10G"        # Modifique si es necesario (ver paso 3)
region="europe"                         # Nombre de la región (ver stackhero regions-list)

# 1. Instalar la CLI en el runner
curl -fsSL https://www.stackhero.io/install.sh | sh

# 2. Instalar el cliente necesario para el smoke test (jq + curl son la base)
apt-get update && apt-get install -y --no-install-recommends jq curl netcat-openbsd

# 3. Crear una stack dedicada para esta ejecución
stackId=$(stackhero --format=script stack-create --name="$stackName")
echo "Stack creada: $stackId"

# 4. Añadir Kafka y capturar su service id
serviceId=$(stackhero --format=script service-add \
  --stack="$stackId" \
  --service-store="$serviceStore" \
  --instance="$instance" \
  --region="$region")
echo "Servicio añadido: $serviceId"

# 5. Esperar a que el servicio esté operativo (puede tardar unos minutos)
stackhero service-wait-for --service="$serviceId"

# 6. Leer la configuración (contiene las credenciales generadas)
config=$(stackhero service-configuration-get --service="$serviceId" --format=json)

# 7. Extraer las credenciales necesarias
host=$(echo "$config" | jq -r '.configuration.domain')

# 8. Smoke test: Open a TCP connection to the broker port.
nc -z -w 5 "$host" 9092

echo "✅ Kafka es accesible desde CI."

El paso de eliminación, que borra el servicio, espera a que se elimine y luego borra la stack, se detalla en las secciones específicas de cada plataforma más abajo. Este enfoque garantiza que la limpieza siempre se realice, incluso si falla el smoke test.

Una stack solo puede eliminarse cuando está vacía. Elimine siempre primero el servicio y espere a que se borre antes de eliminar la stack. El comando service-wait-for asegura que el servicio esté en ejecución o eliminado antes de continuar, por lo que es la herramienta adecuada para esperar la eliminación.