k8s部署kafka集群

Kubernetes 可以很容易地部署 Kafka 集群。下面是一个大致的步骤：

1. 创建一个 Kafka 镜像并将其上传到 Docker Hub 上。Kafka 可以从 Apache Kafka 官网下载并编译。你可以使用 Dockerfile 将其打包成 Docker 镜像。
2. 在 Kubernetes 上安装 ZooKeeper 集群。Kafka 需要 ZooKeeper 来管理其 Brokers。
3. 创建一个 Kafka StatefulSet，它会自动创建多个 Kafka 实例。
4. 在 Kubernetes 上创建一个 Kafka Service，它会将流量路由到 StatefulSet 中的 Kafka 实例上。

下面是一个 YAML 文件示例，用于创建一个 Kafka StatefulSet 和 Service：

apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: kafka
spec:
  serviceName: kafka
  replicas: 3
  selector:
    matchLabels:
      app: kafka
  template:
    metadata:
      labels:
        app: kafka
    spec:
      containers:
      - name: kafka
        image: your-kafka-image
        env:
        - name: KAFKA_ZOOKEEPER_CONNECT
          value: "zookeeper:2181"
        - name: KAFKA_ADVERTISED_LISTENERS
          value: "PLAINTEXT://$(hostname -f):9092"
        ports:
        - containerPort: 9092
  volumeClaimTemplates:
  - metadata:
      name: data
    spec:
      accessModes: [ "ReadWriteOnce" ]
      resources:
        requests:
          storage: 1Gi

---

apiVersion: v1
kind: Service
metadata:
  name: kafka
spec:
  type: NodePort
  selector:
    app: kafka
  ports:
  - name: kafka
    port: 9092
    targetPort: 9092

这个 YAML 文件会创建一个名为 kafka 的 StatefulSet。它会自动创建 3 个 Kafka 实例，并且使用一个名为 data 的 PVC 来存储数据。它还会创建一个名为 kafka 的 Service，它会将流量路由到 Kafka 实例上，这个 Service 的类型是 NodePort，意味着它会将 Kafka 的端口映射到 Kubernetes 集群中的任何节点上。

你可以使用 `kubectl apply -f kafka.yaml` 命令来应用这个 YAML 文件并创建 Kafka 集群。