kubernetes(k8s) helm安装kafka、zookeeper

通过helm在k8s上部署kafka。zookeeper

  通过helm方法安装

  k8s上安装kafka,可以使用helm,将kafka作为一个应用安装。当然这首先要你的k8s支持使用helm安装。helm的介绍和参考见:https://yq.aliyun.com/articles/159601

  helm仓库地址https://github.com/helm/charts

    通过阿里仓库安装kafka

helm repo add incubator https://aliacs-app-catalog.oss-cn-hangzhou.aliyuncs.com/charts-incubator/

  helm repo update

  helm search kafka

kubernetes(k8s) helm安装kafka、zookeeper

  hlem fetch incubator/kafka                    # 下载tgz文件

tar zxf kafka-0.2.1.tgz && cd kafka

把./charts/zookeeper/templates/statefulset.yaml中的zookeeper的镜像地址改为registry.cn-hangzhou.aliyuncs.com/appstore/k8szk:v2

  将以下两个文件中的橘红色部分改为你的storageclass。

  storageclass查询命令: kubectl get sc --all-namespaces   

  kubernetes(k8s) helm安装kafka、zookeeper

  helm install ./ -n kafka  --namespace  xxx   #安装

  kubectl get pvc -n xxx #查看pvc状态

  kubernetes(k8s) helm安装kafka、zookeeper

  kubectl describe pvc  pvcname  -n xxx   #查看pvc详细信息排错使用

  要想外网访问,修改服务的yaml文件,设置type为NodePort为30946

  还要在安全组中开放这个端口

  可以先在pod里面测试

  进入kafka的pod

  创建主题

  bin/kafka-topics.sh --create --zookeeper 10.233.61.237:2181 --replication-factor 1 --partitions 1 --topic device         这里面使用的是集群ip,容器间访问

  创建消费者

  bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic device --from-beginning 

  创建生产者

  bin/kafka-console-producer.sh --broker-list localhost:9092 --topic device     使用本地ip
bin/kafka-console-producer.sh --broker-list 10.233.9.150:9092 --topic device 使用集群id
bin/kafka-console-producer.sh --broker-list 192.168.2.177:30946 --topic device 使用服务器内网ip和nodeport

  现在pod内部可以访问了,现在尝试在外部创建生产者。

  实验发现,在k8s上部署服务来访问k8s上的kafka,依然没有问题。

  下面我们尝试直接在本地pc访问服务器k8s中的kafka。

  在本地电脑上cd到kafka的目录

 cd /home/lp/soft/kafka_2.11-1.1.0
 bin/kafka-console-producer.sh --broker-list 192.168.2.177:30946 --topic device

   发现访问不了。

   进入pod 
     在pod重启kafka。

 bin/kafka-server-stop.sh    关闭

  进入pod,执行

 bin/zookeeper-shell.sh 10.233.61.237:2181 <<< "get /brokers/ids/0"    使用的是zookeeper的集群ip

 

上一篇:Nginx学习笔记六Nginx的模块开发


下一篇:html + js 实现图片上传,压缩,预览及图片压缩后得到Blob对象继续上传问题