k8s部署Kafka集群

Posted 2023-03-09

参考技术A 本次的目的是通过使用k8s搭建一个三节点的 kafka 集群，因为 kafka 集群需要用到存储，所以我们需要准备三个持久卷( Persistent Volume ) 简称就是PV。

首先通过nfs创建三个共享目录

分别对应三节点zk集群中的三个pod的持久化目录，创建好目录之后编写yaml创建 kafka-pv.yaml

使用如下命令创建kafka-pk

出现如下提示就代表创建成功

这是我们可以通过如下命令去查看创建成功的pv

我们选择使用 statefulset 去部署kafka集群的三节点,并且使用刚刚创建的pv作为存储设备。

kafka.yaml

使用 kubectl apply -f kafka.yaml 部署

可以通过 kubect get pods -n tool

可以查看到三个pod都是running状态了，我们再看service状态 可以通过 kubect get svc -n tool

可以看到我们将9092端口通过nodePort映射给了19092暴露出去了。

我们可以通过 kubectl exec -it kafka-1 -n tools /bin/bash 进入容器

创建topic成功 代表我们kafka集群部署成功！！！