Kubernetes+docker-DIY-kafka+zookeeper+manager集群部署
前言：最近在给公司搞kafka和zookeeper容器化结合rancher的项目，查阅了相关官网和书籍，发现如果和公司的标准化关联比较牵强，原因有很多，我简单谈一下我最后选择自定义的原因：（因是个人本地二进制部署k8s+kakfa测试的，因此生产需要自己配置所需要的内存和cpu，动态持久化存储等）
1、使用官网dockfile不能自定义jdk。
2、dockerfile和yaml关联比较牵强，每个人有每个人的思路。
3、不能和公司之前物理机部署标准化文档相结合。
.....
下面，我将花了半个月研究的部署分享一，有兴趣者可加好友共同探讨：
https://github.com/renzhiyuan6666666/kubernetes-docker
创新互联长期为上千多家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为翔安企业提供专业的成都网站制作、成都网站设计，翔安网站改版等技术服务。拥有十多年丰富建站经验和众多成功案例,为您定制开发。
一、 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.12
1.3.2）zookeeper镜像上传harbor仓库
docker login 192.168.8.183 -u admin -p renzhiyuan
docker push 192.168.8.183/library/zookeeper-zyxf
1.4）zookeeper部署
1.4）zookeeper部署
1.4.1）zookeeper部署
kubectl apply -f zookeeper.yaml
1.4.2）zookeeper部署过程检查
[root@node7 ~]# kubectl describe pods zookeeper-
zookeeper-0 zookeeper-1 zookeeper-2
kubectl get pods -w -l app=zookeeper
1.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; done
1.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; done
1.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.0
2.3.2）zookeeper镜像上传harbor仓库
docker login 192.168.8.183 -u admin -p renzhiyuan
docker push 192.168.8.183/library/kafka-zyxf:2.2.0
2.4）kafka部署
2.4.1）kafka部署
kubectl apply -f kafka.yaml
2.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 ; done
2.5.3) 检查 kafka StatefulSet 中FQDN (正式域名)
for i in 0 1 2; do kubectl exec kafka-$i -- hostname -f; done
2.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; done
2.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"; done
2.5.6) 检查 kafka StatefulSet 集群验证
创建一个topic
kubectl 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 renzhiyuan
2.6）kafka集群扩容
2.3.1）kafka扩容到6实例
kubectl scale --replicas=6 StatefulSet/kafka
statefulset.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
创建一个topic
kubectl 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 renzhiyuan
docker push 192.168.8.183/library/kafka-manager-zyxf
3.4）kafka manager 部署
[root@node7 ~]# kubectl apply -f manager.yaml
3.5）kafka manager验证
http://192.168.8.181:32009/
3.5.1）扩容前验证
3.5.2）扩容后验证
网站栏目：Kubernetes+docker-DIY-kafka+zookeeper+manager集群部署
浏览地址：http://pwwzsj.com/article/gpggpg.html
