利用K8S部署zookeeper+kafka集群

椰子ya Linux 2021-07-04

第一次用k8s部署kafka集群,想使用statefulset配合headless部署kafka集群,但是陷入了脚本中broker id怎么写的问题,参考了许多大佬文章,最后在GitHub上找到一个感觉非常nice的利用statefulset部署kafka的脚本。

borker id取值hostname

--override broker.id=${HOSTNAME##*-}

脚本如下>>有道云
第一次搞,耗费了两个半小时。多亏大佬多,自己从头开始写脚本还得想半天

PREV
实验:利用ELK+Filebeat+kafaka搭建大数据日志分析平台
NEXT
M-LAG