前言：最近在给公司搞kafka和zookeeper容器化结合rancher的项目，查阅了相关官网和书籍，发现如果和公司的标准化关联比较牵强，原因有很多，我简单谈一下我最后选择自定义的原因：（因是个人本地二进制部署k8s+kakfa测试的，因此生产需要自己配置所需要的内存和cpu，动态持久化存储等）1、使用官网dockfile不能自定义jdk。2、dockerfile和yaml关联比较牵强，每个人有每个人的思路。3、不能和公司之前物理机部署标准化文档相结合。.....下面，我将花了半个月研究的部署分享一，有兴趣者可加好友共同探讨：https://github.com/renzhiyuan6666666/kubernetes-docker
一、 zookeeper集群部署1.1） zookeeper文件清单2.
1.2） zookeeper文件清单详解1.2.1）oracle jdk软件包 jdk-8u151-linux-x64.tar.gz底层使用centos6.6镜像，部署目录到app目录下，在dockerfile里面配置环境变量。1.2.2）zookeeper软件包 zookeeper-3.4.12.tar.gz底层使用centos6.6镜像，部署目录到app目录下1.2.3）zookeeper Dockerfile
#设置继承镜像 FROM centos:6.6 #作者的信息 MAINTAINER docker_user renzhiyuan #Zookeeper和jdk标准化版本 #ENV JAVA_VERSION="1.8.0_151" #ENV ZK_VERSION="3.4.12" ENV ZK_JDK_HOME=/app ENV JAVA_HOME=/app/jdk1.8.0_151 ENV ZK_HOME=/app/zookeeper ENV LANG=en_US.utf8 #基础使用包安装配置 #RUN yum makecache RUN yum install lsof yum-utils lrzsz net-tools nc -y &>/dev/null #创建安装目录 RUN mkdir $ZK_JDK_HOME #权限和变量 RUN chown -R root.root $ZK_JDK_HOME && chmod -R 755 $ZK_JDK_HOME #安装配置JDK ADD jdk-8u151-linux-x64.tar.gz /app RUN echo "export JAVA_HOME=/app/jdk1.8.0_151" >>/etc/profile RUN echo "export PATH=\$JAVA_HOME/bin:\$PATH" >>/etc/profile RUN echo "export CLASSPATH=.:\$JAVA_HOME/lib/dt.jar:\$JAVA_HOME/lib/tools.jar" >>/etc/profile && source /etc/profile #安装配置zookeeper-3.4.12,相关目录整合到安装包 ADD zookeeper-3.4.12.tar.gz /app RUN ln -s /app/zookeeper-3.4.12 /app/zookeeper #配置文件,日志切割，jvm标准化单独在zkGenConfig.sh配置 COPY zkGenConfig.sh /app/zookeeper/bin/ #开放端口 EXPOSE 2181 10052
1.2.4）zkGenConfig.sh # !/usr/bin/env # Copyright 2016 The Kubernetes Authors. # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. #配置ZK相关变量 #ZK_USER=${ZK_USER:-"root"} #ZK_LOG_LEVEL=${ZK_LOG_LEVEL:-"INFO"} #ZK_HOME=${ZK_HOME:-"/app/zookeeper"} ZK_DATA_DIR=${ZK_DATA_DIR:-"/app/zookeeper/data"} ZK_DATA_LOG_DIR=${ZK_DATA_LOG_DIR:-"/app/zookeeper/datalog"} ZK_LOG_DIR=${ZK_LOG_DIR:-"/app/zookeeper/logs"} ZK_CONF_DIR=${ZK_CONF_DIR:-"/app/zookeeper/conf"} LOGGER_PROPS_FILE="$ZK_CONF_DIR/log4j.properties" #ZK_CLIENT_PORT=${ZK_CLIENT_PORT:-2181} #ZK_SERVER_PORT=${ZK_SERVER_PORT:-2222} #ZK_ELECTION_PORT=${ZK_ELECTION_PORT:-2223} #ZK_TICK_TIME=${ZK_TICK_TIME:-3000} #ZK_INIT_LIMIT=${ZK_INIT_LIMIT:-10} #ZK_SYNC_LIMIT=${ZK_SYNC_LIMIT:-5} #ZK_MAX_CLIENT_CNXNS=${ZK_MAX_CLIENT_CNXNS:-100} #ZK_MIN_SESSION_TIMEOUT=${ZK_MIN_SESSION_TIMEOUT:- $((ZK_TICK_TIME*2))} #ZK_MAX_SESSION_TIMEOUT=${ZK_MAX_SESSION_TIMEOUT:- $((ZK_TICK_TIME*20))} #ZK_SNAP_RETAIN_COUNT=${ZK_SNAP_RETAIN_COUNT:-3} #ZK_PURGE_INTERVAL=${ZK_PURGE_INTERVAL:-0} ID_FILE="$ZK_DATA_DIR/myid" ZK_CONFIG_FILE="$ZK_CONF_DIR/zoo.cfg" JAVA_ENV_FILE="$ZK_CONF_DIR/java.env" #副本数 #ZK_REPLICAS=3 #配置主机名和domain HOST=`hostname -s` DOMAIN=`hostname -d` #ipdrr=`ip a|grep eth2|grep inet|awk '{print $2}'|awk -F"/" '{print $1}'` #配置选举端口和数据同步端口 function print_servers() { for (( i=1; i<=$ZK_REPLICAS; i++ )) do echo "server.$i=$NAME-$((i-1)).$DOMAIN:$ZK_SERVER_PORT:$ZK_ELECTION_PORT" done } #获取hostName的最后一位，比如zookeeper-0获取到0作为myid function validate_env() { echo "Validating environment" if [ -z $ZK_REPLICAS ]; then echo "ZK_REPLICAS is a mandatory environment variable" exit 1 fi if [[ $HOST =~ (.*)-([0-9]+)$ ]]; then NAME=${BASH_REMATCH[1]} ORD=${BASH_REMATCH[2]} else echo "Failed to extract ordinal from hostname $HOST" exit 1 fi MY_ID=$((ORD+1)) if [ ! -f $ID_FILE ]; then echo $MY_ID >> $ID_FILE fi #echo "ZK_REPLICAS=$ZK_REPLICAS" #echo "MY_ID=$MY_ID" #echo "ZK_LOG_LEVEL=$ZK_LOG_LEVEL" #echo "ZK_DATA_DIR=$ZK_DATA_DIR" #echo "ZK_DATA_LOG_DIR=$ZK_DATA_LOG_DIR" #echo "ZK_LOG_DIR=$ZK_LOG_DIR" #echo "ZK_CLIENT_PORT=$ZK_CLIENT_PORT" #echo "ZK_SERVER_PORT=$ZK_SERVER_PORT" #echo "ZK_ELECTION_PORT=$ZK_ELECTION_PORT" #echo "ZK_TICK_TIME=$ZK_TICK_TIME" #echo "ZK_INIT_LIMIT=$ZK_INIT_LIMIT" #echo "ZK_SYNC_LIMIT=$ZK_SYNC_LIMIT" #echo "ZK_MAX_CLIENT_CNXNS=$ZK_MAX_CLIENT_CNXNS" #echo "ZK_MIN_SESSION_TIMEOUT=$ZK_MIN_SESSION_TIMEOUT" #echo "ZK_MAX_SESSION_TIMEOUT=$ZK_MAX_SESSION_TIMEOUT" #echo "ZK_HEAP_SIZE=$ZK_HEAP_SIZE" #echo "ZK_SNAP_RETAIN_COUNT=$ZK_SNAP_RETAIN_COUNT" #echo "ZK_PURGE_INTERVAL=$ZK_PURGE_INTERVAL" #echo "ENSEMBLE" #print_servers #echo "Environment validation successful" } #配置ZK配置文件变量 function create_config() { #rm -f $ZK_CONFIG_FILE echo "dataDir=$ZK_DATA_DIR" >>$ZK_CONFIG_FILE echo "dataLogDir=$ZK_DATA_LOG_DIR" >>$ZK_CONFIG_FILE echo "tickTime=$ZK_TICK_TIME" >>$ZK_CONFIG_FILE echo "initLimit=$ZK_INIT_LIMIT" >>$ZK_CONFIG_FILE echo "syncLimit=$ZK_SYNC_LIMIT" >>$ZK_CONFIG_FILE echo "clientPort=$ZK_CLIENT_PORT" >>$ZK_CONFIG_FILE echo "maxClientCnxns=$ZK_MAX_CLIENT_CNXNS" >>$ZK_CONFIG_FILE if [ $ZK_REPLICAS -gt 1 ]; then print_servers >> $ZK_CONFIG_FILE fi echo "Write ZooKeeper configuration file to $ZK_CONFIG_FILE" } #创建ZK相关目录和myid #function create_data_dirs() { # echo "Creating ZooKeeper data directories and setting permissions" # # if [ ! -d $ZK_DATA_DIR ]; then # mkdir -p $ZK_DATA_DIR # chown -R $ZK_USER:$ZK_USER $ZK_DATA_DIR # fi # # if [ ! -d $ZK_DATA_LOG_DIR ]; then # mkdir -p $ZK_DATA_LOG_DIR # chown -R $ZK_USER:$ZK_USER $ZK_DATA_LOG_DIR # fi # # if [ ! -d $ZK_LOG_DIR ]; then # mkdir -p $ZK_LOG_DIR # chown -R $ZK_USER:$ZK_USER $ZK_LOG_DIR # fi # # echo "Created ZooKeeper data directories and set permissions in $ZK_DATA_DIR" #} #配置日志切割 #function create_log_props () { # rm -f $LOGGER_PROPS_FILE # echo "Creating ZooKeeper log4j configuration" # echo "zookeeper.root.logger=CONSOLE" >> $LOGGER_PROPS_FILE # echo "zookeeper.console.threshold="$ZK_LOG_LEVEL >> $LOGGER_PROPS_FILE # echo "log4j.rootLogger=\${zookeeper.root.logger}" >> $LOGGER_PROPS_FILE # echo "log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender" >> $LOGGER_PROPS_FILE # echo "log4j.appender.CONSOLE.Threshold=\${zookeeper.console.threshold}" >> $LOGGER_PROPS_FILE # echo "log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout" >> $LOGGER_PROPS_FILE # echo "log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} [myid:%X{myid}] - %-5p [%t:%C{1}@%L] - %m%n" >> $LOGGER_PROPS_FILE # echo "Wrote log4j configuration to $LOGGER_PROPS_FILE" #} #配置启动jmx配置 function create_java_env() { rm -f $JAVA_ENV_FILE echo "Creating JVM configuration file" echo '#!/bin/bash' >> $JAVA_ENV_FILE echo "export JMXPORT=10052" >> $JAVA_ENV_FILE echo "JVMFLAGS=\"\$JVMFLAGS -Xms256m -Xmx256m -Djute.maxbuffer=5000000 -Xloggc:gc.log -XX:+PrintGCApplicationStoppedTime -XX:+PrintGCApplicationConcurrentTime -XX:+PrintGC -XX:+PrintGCTimeStamps -XX:+PrintGCDetails -XX:ParallelGCThreads=8 -XX:+UseConcMarkSweepGC\"" >> $JAVA_ENV_FILE echo "Wrote JVM configuration to $JAVA_ENV_FILE" } validate_env && create_config && create_java_env && cat $ZK_CONFIG_FILE && cat $JAVA_ENV_FILE
1.2.5）zookeeper.yaml # !/usr/bin/env #部署 Service Headless，用于Zookeeper间相互通信 apiVersion: v1 kind: Service metadata: name: zookeeper-headless labels: app: zookeeper spec: clusterIP: None publishNotReadyAddresses: true ports: - name: client port: 2181 targetPort: client - name: server port: 2222 targetPort: server - name: leader-election port: 2223 targetPort: leader-election selector: app: zookeeper --- #部署 Service，用于外部访问 Zookeeper apiVersion: v1 kind: Service metadata: name: zookeeper labels: app: zookeeper spec: type: NodePort ports: - name: client port: 2181 targetPort: 2181 nodePort: 32181 protocol: TCP selector: app: zookeeper --- #配置控制器保证POD集群处于运行状态最低个数 apiVersion: policy/v1beta1 kind: PodDisruptionBudget metadata: name: zk-pdb spec: selector: matchLabels: app: zookeeper minAvailable: 2 --- #配置StatefulSet apiVersion: apps/v1beta2 kind: StatefulSet metadata: name: zookeeper spec: podManagementPolicy: OrderedReady replicas: 3 revisionHistoryLimit: 10 selector: matchLabels: app: zookeeper serviceName: zookeeper-headless template: metadata: annotations: labels: app: zookeeper spec: affinity: podAntiAffinity: requiredDuringSchedulingIgnoredDuringExecution: - labelSelector: matchExpressions: - key: "app" operator: In values: - zookeeper topologyKey: "kubernetes.io/hostname" containers: - name: zookeeper imagePullPolicy: Always image: 192.168.8.183/library/zookeeper-zyxf:3.4.12 resources: requests: memory: "512m" cpu: "500m" ports: - containerPort: 2181 name: client - containerPort: 2222 name: server - containerPort: 2223 name: leader-election env: - name : ZK_REPLICAS value: "3" - name : ZK_DATA_DIR value: "/app/zookeeper/data" - name : ZK_DATA_LOG_DIR value: "/app/zookeeper/dataLog" - name : ZK_TICK_TIME value: "3000" - name : ZK_INIT_LIMIT value: "10" - name : ZK_SYNC_LIMIT value: "5" - name : ZK_MAX_CLIENT_CNXNS value: "100" - name: ZK_CLIENT_PORT value: "2181" - name: ZK_SERVER_PORT value: "2222" - name: ZK_ELECTION_PORT value: "2223" command: - sh - -c - /app/zookeeper/bin/zkGenConfig.sh && /app/zookeeper/bin/zkServer.sh start-foreground volumeMounts: - name: datadir mountPath: /app/zookeeper/dataLog volumes: - name: datadir hostPath: path: /zk type: DirectoryOrCreate # volumeMounts: # - name: data # mountPath: /renzhiyuan/zookeeper # volumeClaimTemplates: # - metadata: # name: data # spec: # accessModes: [ "ReadWriteOnce" ] # storageClassName: local-storage # resources: # requests: # storage: 3Gi *
1.3）zookeeper镜像生成上传1.3.1）zookeeper镜像打包docker build -t zookeeper:3.4.12 -f zookeeper.Dockerfile .docker tag zookeeper:3.4.12 192.168.8.183/library/zookeeper-zyxf:3.4.121.3.2）zookeeper镜像上传harbor仓库docker login 192.168.8.183 -u admin -p renzhiyuandocker push 192.168.8.183/library/zookeeper-zyxf
1.4）zookeeper部署1.4）zookeeper部署1.4.1）zookeeper部署kubectl apply -f zookeeper.yaml1.4.2）zookeeper部署过程检查[root@node7 ~]# kubectl describe pods zookeeper-zookeeper-0 zookeeper-1 zookeeper-2kubectl get pods -w -l app=zookeeper1.5） zookeeper集群验证1.5.1）检查 zookeeper StatefulSet 中 Pods 分布[root@node7 ~]# kubectl get pods -o wide
1.5.2）检查 zookeeper StatefulSet 中 Pods 主机名for i in 0 1 2; do kubectl exec zookeeper-$i – hostname ; done
1.5.3) 检查 zookeeper StatefulSet 中myid标识for i in 0 1 2; do echo "myid zookeeper-$i";kubectl exec zookeeper-$i -- cat /app/zookeeper/data/myid; done
1.5.4) 检查 zookeeper StatefulSet 中FQDN (正式域名)for i in 0 1 2; do kubectl exec zookeeper-$i -- hostname -f; done1.5.5) 检查 zookeeper StatefulSet pods中dns解析for i in 0 1 2; do kubectl exec -ti busybox -- nslookup zookeeper-$i.zookeeper-headless.default.svc.cluster.local; done1.5.6) 检查 zookeeper StatefulSet zoo.cfg配置文件标准化1.5.7) 检查 zookeeper StatefulSet 集群状态for i in 0 1 2; do kubectl exec zookeeper-$i -- /app/zookeeper/bin/zkServer.sh status|grep Mode; done
1.5.8) 检查 zookeeper StatefulSet 四字命令检验
1.6） zookeeper集群扩容二、 kafka集群部署2.1）kafka文件清单
2.2） kafka文件清单详解2.2.1）oracle jdk软件包 jdk-8u151-linux-x64.tar.gz底层使用centos6.6镜像，部署目录到app目录下，在dockerfile里面配置环境变量。2.2.2）zookeeper软件包 kafka_2.12-2.2.0.tar.gz底层使用centos6.6镜像，部署目录到app目录下2.2.3）kafka Dockerfile
#设置继承镜像 FROM centos:6.6 #作者的信息 MAINTAINER docker_user （renzhiyuan@docker.com） #kafka和jdk标准化版本 ENV JAVA_VERSION="1.8.0_151" ENV KAFKA_VERSION="2.2.0" ENV KAFKA_JDK_HOME=/app ENV JAVA_HOME=/app/jdk1.8.0_151 ENV KAFKA_HOME=/app/kafka ENV LANG=en_US.utf8 #基础使用包安装配置 #RUN yum makecache RUN yum install lsof yum-utils lrzsz net-tools nc -y &>/dev/null #创建安装目录 RUN mkdir $KAFKA_JDK_HOME #权限和变量 RUN chown -R root.root $KAFKA_JDK_HOME && chmod -R 755 $KAFKA_JDK_HOME #安装配置JDK ADD jdk-8u151-linux-x64.tar.gz /app RUN echo "export JAVA_HOME=/app/jdk1.8.0_151" >>/etc/profile RUN echo "export PATH=\$JAVA_HOME/bin:\$PATH" >>/etc/profile RUN echo "export CLASSPATH=.:\$JAVA_HOME/lib/dt.jar:\$JAVA_HOME/lib/tools.jar" >>/etc/profile #安装配置Kafka和创建目录 ADD kafka_2.12-2.2.0.tar.gz /app RUN ln -s /app/kafka_2.12-2.2.0 /app/kafka #配置文件,日志切割，jvm标准化单独在kafkaGenConfig.sh配置 #开放端口 EXPOSE 9092 9999
2.2.4）kafka.yaml #部署 Service Headless，用于Kafka间相互通信 apiVersion: v1 kind: Service metadata: name: kafka-headless labels: app: kafka spec: type: ClusterIP clusterIP: None ports: - name: kafka port: 9092 targetPort: kafka selector: app: kafka --- #部署 Service，用于外部访问 kafka apiVersion: v1 kind: Service metadata: name: kafka labels: app: kafka spec: type: NodePort ports: - name: kafka port: 9092 targetPort: 9092 nodePort: 32192 protocol: TCP selector: app: kafka --- #配置控制器保证POD集群处于运行状态最低个数 apiVersion: policy/v1beta1 kind: PodDisruptionBudget metadata: name: kafka-pdb spec: selector: matchLabels: app: kafka minAvailable: 2 --- #配置StatefulSet apiVersion: apps/v1beta2 kind: StatefulSet metadata: name: kafka spec: podManagementPolicy: OrderedReady replicas: 3 revisionHistoryLimit: 10 selector: matchLabels: app: kafka serviceName: kafka-headless template: metadata: annotations: labels: app: kafka spec: affinity: podAntiAffinity: requiredDuringSchedulingIgnoredDuringExecution: - labelSelector: matchExpressions: - key: "app" operator: In values: - kafka topologyKey: "kubernetes.io/hostname" containers: - name: kafka imagePullPolicy: Always image: 192.168.8.183/library/kafka-zyxf:2.2.0 resources: requests: memory: "500m" cpu: "256m" ports: - containerPort: 9092 name: kafka env: - name: KAFKA_HEAP_OPTS value : "-Xmx256M -Xms256M" command: - sh - -c - "/app/kafka/bin/kafka-server-start.sh /app/kafka/config/server.properties \ --override broker.id=${HOSTNAME##*-} \ --override zookeeper.connect=zookeeper:2181 \ --override listeners=PLAINTEXT://:9092 \ --override advertised.listeners=PLAINTEXT://:9092 \ --override broker.id.generation.enable=false \ --override auto.create.topics.enable=false \ --override min.insync.replicas=2 \ --override log.dir= \ --override log.dirs=/app/kafka/kafka-logs \ --override offsets.retention.minutes=10080 \ --override default.replication.factor=3 \ --override queued.max.requests=2000 \ --override num.network.threads=8 \ --override num.io.threads=16 \ --override auto.create.topics.enable=false \ --override socket.send.buffer.bytes=1048576 \ --override socket.receive.buffer.bytes=1048576 \ --override num.replica.fetchers=4 \ --override replica.fetch.max.bytes=5242880 \ --override replica.socket.receive.buffer.bytes=1048576" volumeMounts: - name: datadir mountPath: /app/kafka/kafka-logs volumes: - name: datadir hostPath: path: /kafka type: DirectoryOrCreate # emptyDir: {} # volumeMounts: # - name: data # mountPath: /renzhiyuan/kafka # volumeClaimTemplates: # - metadata: # name: data # spec: # accessModes: [ "ReadWriteOnce" ] # storageClassName: local-storage # resources: # requests: # storage: 3Gi
2.3）kafka镜像生成上传2.3.1）zookeeper镜像打包docker build -t kafka:2.2.0 -f kafka.Dockerfile .docker tag kafka:2.2.0 192.168.8.183/library/kafka-zyxf:2.2.02.3.2）zookeeper镜像上传harbor仓库docker login 192.168.8.183 -u admin -p renzhiyuandocker push 192.168.8.183/library/kafka-zyxf:2.2.02.4）kafka部署2.4.1）kafka部署kubectl apply -f kafka.yaml2.4.2）kafka部署过程检查[root@node7 ~]# kubectl describe pods kafka-kafka-0 kafka-1 kafka-2 [root@node7 ~]# kubectl get pods -w -l app=kafka
2.5）kafka集群验证2.5.1）检查 kafka StatefulSet 中 Pods 分布2.5.2）检查 kafka StatefulSet 中 Pods 主机名for i in 0 1 2; do kubectl exec kafka-$i -- hostname ; done2.5.3) 检查 kafka StatefulSet 中FQDN (正式域名)for i in 0 1 2; do kubectl exec kafka-$i -- hostname -f; done2.5.4) 检查 kafka StatefulSet pods中dns解析for i in 0 1 2; do kubectl exec -ti busybox -- nslookup kafka-$i.kafka-headless.default.svc.cluster.local; done2.5.5) 检查 kafka StatefulSet server.properties配置文件标准化for i in 0 1 2; do echo kafka-$i; kubectl exec kafka-$i cat /app/kafka/logs/server.log|grep "auto.create.topics.enable = false"; done2.5.6) 检查 kafka StatefulSet 集群验证 创建一个topickubectl exec kafka-1 -- /app/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 3 --partitions 6 --topic renzhiyuan 检查topic信息kubectl exec kafka-1 -- /app/kafka/bin/kafka-topics.sh --describe --zookeeper zookeeper:2181 --topic renzhiyuan 生产消息/app/kafka/bin/kafka-console-producer.sh --broker-list kafka:9092 --topic renzhiyuan 消费消息/app/kafka/bin/kafka-console-consumer.sh --bootstarp-server kafka:9092 --from-beginning --topic renzhiyuan2.6）kafka集群扩容2.3.1）kafka扩容到6实例kubectl scale --replicas=6 StatefulSet/kafkastatefulset.apps/kafka scaled[root@node7 ~]#2.3.2）kafka扩容过程检查[root@node7 ~]# kubectl describe pods kafka-kafka-0 kafka-2 kafka-4 kafka-1 kafka-3 kafka-5 [root@node7 ~]# kubectl get pods -w -l app=kafka 创建一个topickubectl exec kafka-3 -- /app/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 3 --partitions 6 --topic renzhiyuan2 检查topic信息kubectl exec kafka-3 -- /app/kafka/bin/kafka-topics.sh --describe --zookeeper zookeeper:2181 --topic renzhiyuan2三、 Kafka manager管理端部署3.1）kafka manager文件清单
3.2） kafka manager文件清单详解3.3）kafka manager 镜像生成上传3.3.1）zookeeper镜像打包docker build -t kafka-manager:1.3.3.18 -f manager.Dockerfile .docker tag kafka-manager:1.3.3.18 192.168.8.183/library/ kafka-manager-zyxf: 1.3.3.18 3.3.2）zookeeper镜像上传harbor仓库docker login 192.168.8.183 -u admin -p renzhiyuandocker push 192.168.8.183/library/kafka-manager-zyxf3.4）kafka manager 部署[root@node7 ~]# kubectl apply -f manager.yaml3.5）kafka manager验证http://192.168.8.181:32009/ 3.5.1）扩容前验证
3.5.2）扩容后验证