Kafka: 4. GitHub Actions
Esta documentação faz parte do guia GitHub Actions & GitLab CI. Consulte o guia completo aqui: Inicie um serviço real de Kafka a partir do seu pipeline do GitHub Actions ou GitLab CI, execute os seus testes sobre ele e elimine-o automaticamente.
👋 Bem-vindo à documentação da Stackhero!
A Stackhero oferece-lhe um ambiente Kafka cloud totalmente gerido, pronto em poucos minutos. Eis o que pode esperar:
- Sem limites no tamanho ou transferência de mensagens: escale os seus dados sem preocupações com restrições.
- Atualizações simples, com um clique, mantêm a sua plataforma atualizada sem interrupções ou trabalho manual.
- Desempenho elevado e segurança robusta de forma consistente, na sua própria infraestrutura privada e dedicada.
Se pretende acelerar processos e reduzir a carga operacional, a Stackhero disponibiliza alojamento Kafka cloud para o ajudar. Pode ter um cluster pronto para produção em cerca de 5 minutos.
Para começar, guarde o seguinte conteúdo como .github/workflows/ci.yml. A partir de agora, cada push e pull request irá executar testes contra uma instância real de Kafka.
name: CI com 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" # Altere se necessário (ver passo 3)
REGION: europe
steps:
- uses: actions/checkout@v4
- name: Instalar o Stackhero CLI e o 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: Criar o serviço 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: Executar testes 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 está acessível a partir do CI."
# Pode executar a sua própria suite de testes aqui usando as credenciais acima ...
- name: Limpeza (sempre, mesmo em caso de falha)
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
O passo de limpeza está configurado com if: always() para garantir que é sempre executado, assegurando que a sua instância de Kafka é eliminada e que não será cobrado por recursos não utilizados.