Kafka: 4. GitHub Actions
Ši dokumentacija yra GitHub Actions ir GitLab CI vadovo dalis. Visą vadovą rasite čia: Paleiskite tikrą Kafka paslaugą iš savo GitHub Actions arba GitLab CI pipeline, vykdykite testus ir automatiškai viską uždarykite.
👋 Sveiki atvykę į Stackhero dokumentaciją!
Stackhero suteikia visiškai valdomą Kafka cloud aplinką, paruoštą naudoti per kelias minutes. Štai ko galite tikėtis:
- Nėra jokių apribojimų žinučių dydžiui ar perdavimui: auginkite savo duomenis be jokių ribojimų.
- Paprasti, vieno paspaudimo atnaujinimai leidžia platformą nuolat atnaujinti be prastovų ar rankinio darbo.
- Nuoseklus aukštas našumas ir patikima saugumo sistema jūsų privataus, dedikuoto infrastruktūros pagrindu.
Jei norite judėti greičiau ir sumažinti operacinę naštą, Stackhero siūlo Kafka cloud hosting, kuris padės jums tai pasiekti. Gamybinės parengties klasterį galite turėti maždaug per 5 minutes.
Norėdami pradėti, išsaugokite žemiau pateiktą turinį kaip .github/workflows/ci.yml. Nuo šiol kiekvienas push ir pull request vykdys testus prieš tikrą Kafka instanciją.
name: CI su 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" # Pakeiskite jei reikia (žr. 3 žingsnį)
REGION: europe
steps:
- uses: actions/checkout@v4
- name: Įdiegti Stackhero CLI ir klientą
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: Sukurti Kafka paslaugą
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: Vykdyti testus prieš 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 pasiekiamas iš CI."
# Čia galite paleisti savo testų rinkinį naudodami aukščiau gautus prisijungimo duomenis ...
- name: Išvalymas (visada, net jei įvyksta klaida)
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
Teardown žingsnis naudoja if: always(), todėl jis bus vykdomas visada, užtikrinant, kad jūsų Kafka instancija bus ištrinta ir jums nebus skaičiuojami mokesčiai už nenaudojamus resursus.