一、创建 NFS 存储

主机安装nfs
yum -y install nfs-utils
yum -y install rpcbind
创建目录
mkdir -p /data/opv
vi /etc/exports
/data/opv *(rw,sync,no_root_squash)
重启生效
systemctl restart rpcbind
systemctl restart nfs
systemctl enable nfs
测试nfs
showmount -e 192.168.6.1
rbac.yaml
nfs-client.yaml
storageclass.yaml

二、创建zookpeer和 kafka

创建namespeace
kubelet create ns kafka
zk.yaml
kafka.yaml

三、开始测试

首先执行如下命令创建一个生产者，用于往 my-topic 这个主题发送消息：

  1. kubectl -n kafka run kafka-producer -ti --image=quay.io/strimzi/kafka:0.22.1-kafka-2.7.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --broker-list my-cluster-kafka-bootstrap:9092 --topic my-topic

接着重新再打开一个终端连接服务器，执行如下命令创建一个消费者，用于消费 my-topic 这个主题的消息：

  1. kubectl -n kafka run kafka-consumer -ti --image=quay.io/strimzi/kafka:0.22.1-kafka-2.7.0 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --topic my-topic --from-beginning

会产生一个单独的pod一个发送一个接收信息