Kafka: 2. 生命周期脚本
本文档属于GitHub Actions & GitLab CI指南的一部分。您可以在此处查看完整指南：通过您的 GitHub Actions 或 GitLab CI 流水线启动一个真实的 Kafka 服务，运行测试并自动销毁。
👋 欢迎查阅 Stackhero 文档！
Stackhero 为您提供全托管的 Kafka cloud 环境，几分钟内即可就绪。您将获得：
- 消息大小与传输无限制：数据扩展无上限，无需担心限制。
- 一键式简单升级：平台始终保持最新，无需停机或手动操作。
- 在您专属的私有、专用基础设施上，持续享有高性能与强大安全性。
如果您希望加快部署速度并减少运维负担，Stackhero 提供的 Kafka cloud hosting 能为您助力。大约 5 分钟即可拥有可用于生产环境的集群。
以下是一个完整的服务生命周期管理脚本示例。它展示了只需极少的配置和几条命令即可完成全部流程。您可以在下方各平台专属部分复制对应的 YAML 配置。
#!/bin/bash
set -euo pipefail
# STACKHERO_TOKEN 由 CI 密钥提供，CLI 会自动读取。
stackName="ci-kafka-$$" # 每次运行唯一的 stack 名称
serviceStore="kafka" # Kafka 服务 store
instance="10G" # 如有需要可修改（见第 3 步）
region="europe" # 区域名称（可通过 stackhero regions-list 查看）
# 1. 在 runner 上安装 CLI
curl -fsSL https://www.stackhero.io/install.sh | sh
# 2. 安装 smoke test 所需客户端（jq + curl 为基础）
apt-get update && apt-get install -y --no-install-recommends jq curl netcat-openbsd
# 3. 为本次运行创建专用 stack
stackId=$(stackhero --format=script stack-create --name="$stackName")
echo "Stack created: $stackId"
# 4. 添加 Kafka 并获取其 service id
serviceId=$(stackhero --format=script service-add \
--stack="$stackId" \
--service-store="$serviceStore" \
--instance="$instance" \
--region="$region")
echo "Service added: $serviceId"
# 5. 等待服务运行（可能需要几分钟）
stackhero service-wait-for --service="$serviceId"
# 6. 读取配置（包含生成的凭据）
config=$(stackhero service-configuration-get --service="$serviceId" --format=json)
# 7. 提取所需凭据
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 已可从 CI 访问。"
销毁步骤（删除服务、等待其移除、再删除 stack）请参见下方各平台专属部分。此方式确保即使 smoke test 失败也能始终完成清理。
stack 只能在为空时删除。请务必先删除服务并等待其移除，再删除 stack。
service-wait-for命令可确保服务已运行或已删除，是等待删除的最佳工具。