标签：完爆 test001 4.2 -- zookeeper kafka helm
目录一、环境准备
- Kubernetes：v1.18.13
- Kubernetes宿主机：CentOS Linux release 7.6.1810 (Core)
- Nfs服务器：192.168.99.151
- Helm：v3.6.1
- Kafka：2.0.1
- Zookeeper：3.5.5
接下来的实战之前，请您准备好：K8S、Helm、NFS、StorageClass！
二、准备工作
2.1 添加helm仓库(该仓库中有kafka)：
$ helm repo add incubator http://storage.googleapis.com/kubernetes-charts-incubator
# 如果上述命令添加仓库失败了 可以使用以下命令进行添加
$ helm repo add incubator https://charts.helm.sh/incubator
2.2 获取kafka的chart包
$ helm pull incubator/kafka --untar
2.3 修改具体的values 对应的值
1） 首先要设置在K8S之外的也能使用kafka服务，修改external.enabled的值，改为true！
2）找到configurationOverrides，下图两个框中的内容原本是注释的，请删除注释符号，另外，如果您之前设置过跨网络访问kafka，就能理解下面写入K8S宿主机IP的原因了！
3）设置数据卷，找到persistence，按需要调整大小，再设置已准备好的storageclass的名称！
4）设置zookeeper的数据卷！
三、部署
3.1 先创建namespace
$ kubectl create namespace kafka-test
3.2 安装
$ helm -n kafka-test install kafka ../kafka/ -f values.yaml
kafka启动依赖zookeeper，整个启动会耗时数分钟，期间可见zookeeper和kafka的pod逐渐启动！
3.3 查看kafka的版本
$ kubectl exec kafka-0 -n kafka-test -- sh -c 'ls /usr/share/java/kafka/kafka_*.jar'
如下图红框所示，scala版本2.11，kafka版本2.0.1：
四、验证
4.1 对外暴露zookeeper
apiVersion: v1
kind: Service
metadata:
name: zookeeper-nodeport
namespace: kafka-test
spec:
type: NodePort
ports:
- port: 2181
nodePort: 32181
selector:
app: zookeeper
release: kafka
4.2 验证
找一台电脑安装kafka包，就能通过里面自带的命令远程连接和操作K8S的kafka了！
4.2.1 安装kafka软件包
访问kafka官网：http://kafka.apache.org/downloads ，刚才确定了scala版本2.11，kafka版本2.0.1，因此下载下图红框中的版本：
4.2.2 查看当前topic
$ ./kafka-topics.sh --list --zookeeper 192.168.99.151:32181
# 空空如也
4.2.3 创建topic
$ ./kafka-topics.sh --create --zookeeper 192.168.99.151:32181 --replication-factor 1 --partitions 1 --topic test001
4.2.4 查看名为test001的topic
$ ./kafka-topics.sh --describe --zookeeper 192.168.99.151:32181 --topic test001
Topic:test001 PartitionCount:1 ReplicationFactor:1 Configs:
Topic: test001 Partition: 0 Leader: 1 Replicas: 1 Isr: 1
4.2.5 进入创建消息的交互模式
$ ./kafka-console-producer.sh --broker-list 192.168.99.151:31090 --topic test001
4.2.6 执行命令消费消息
$ ./kafka-console-consumer.sh --bootstrap-server 192.168.99.151:31090 --topic test001 --from-beginning
自行测试！ 本人暂时对kafka 没什么深入研究 ！ 随后有时间继续完善！
标签：完爆,test001,4.2,--,zookeeper,kafka,helm 来源： https://www.cnblogs.com/lvzhenjiang/p/14971932.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。