kafka operator
Kafka Operator 构建于 Operator framework 之上,用于在 Kubernetes 上快速搭建Apache Kafka集群。
本项目为简易版本,为了简单可控性而自研并逐渐完善,可作为Operator framework有状态服务的开发例子。如果需要更完善的Operator,有以下项目可以参考。
# build your own operator image
git clone https://github.com/k8s-operators/kafka-operator.git
cd kafka-operator
operator-sdk generate k8s
operator-sdk build your-docker-name/kafka-operator:v1.0.0
docker push your-docker-name/kafka-operator:v1.0.0
# replace deploy/operator.yaml to use your operator image
# or just use jianzhiunique/kafka-operator:v1.0.0
# deploy files under "deploy" dir to server
kubectl apply -f service_account.yaml
kubectl apply -f role.yaml
kubectl apply -f role_binding.yaml
kubectl apply -f operator.yaml
kubectl apply -f deploy/crds/jianzhiunique.github.io_kafkas_crd.yaml
# config cr.yaml
# for all fields, see pkg/apis/jianzhiunique/v1/kafka_types.go
# we apply some default values for you, see pkg/utils/check_cr.go
# the only config that you must specify is storage_class_name,
# for kafka, we recommend users to use local pv