最近在学习DDD Event Storming以及ETL工具时,对Apache Kafka产生了很大的兴趣,准备搭建一套Development环境方便之后的学习。
部署Kafka集群
在Kubernetes上部署
部署Strimzi Operator
对比了很多种安装方式,本文将选择使用strimzi + Helm方式部署,简单高效,而且也可在生产环境中部署。strimzi提供了一个Operator来创建Kafka集群,如果想换其他方式,可以选择Bitnami的Kafka Helm Chart。
1)首先第一步添加strimzi的helm repo:
2)之后下载官方的Helm Values,其中很多镜像是quay.io仓库的,导致无法下载,这里已经替换成了个人的docker镜像。
3)执行如下Helm命令部署strimzi operator:
创建Kafka集群
将如下脚本,保存为:kafka-persistent-single.yaml
执行如下脚本:
观察POD启动情况:
验证结果
生产者消费者的脚本如下:
实际演示效果:
以上可以看出Kafka集群已经部署成功,并能成功发送消息以及接收消息。
Docker Compose部署
docker-compose.yaml脚本内容如下:
使用docker-compose命令启动后,Mac电脑安装Conduktor软件验证,如下图所示:
Reference
- Apache Kafka官网:https://kafka.apache.org/
- Strimzi官网:https://strimzi.io/
「真诚赞赏,手留余香」
请我喝杯咖啡?
使用微信扫描二维码完成支付
