Skip to content

Latest commit

 

History

History
122 lines (115 loc) · 5.05 KB

kafka.md

File metadata and controls

122 lines (115 loc) · 5.05 KB
Raw

kafka-Operators 安装

依赖条件

开启 Rabbitmq-Operators 组件

  1. 编辑 /etc/kubez/globals.yml

  2. 取消 enable_kafka: "no"的注释，并设置为 "yes", 取消kafka_name: kafka的注释,自定义设置kafka集群名称， 取消 kafka_namespace: operators的注释，自定义namespace

    ###############
# kafka Options
###############
enable_kafka: "yes"

kafka_name: kafka
kafka_namespace: operators

  3. 执行安装命令（根据实际情况选择）

    # 单节点集群场景
kubez-ansible apply
# 高可用集群场景
kubez-ansible -i multinode apply

  4. 部署完验证

    # rabbitmq 已注册至集群中
kubectl get csv -n operators
[root@VM-4-3-centos ~]# kubectl get csv -n operators
NAME                               DISPLAY   VERSION   REPLACES                           PHASE
strimzi-cluster-operator.v0.33.0   Strimzi   0.33.0    strimzi-cluster-operator.v0.32.0   Succeeded

至此 kafka Operator 已安装至集群中, 接下来展示 kafka 实例的创建。

创建 kafka CR 实例

  1. 修改 yaml 文件（根据实际情况选择具体参数） 
     apiVersion: kafka.strimzi.io/v1beta2
 kind: Kafka
 metadata:
   name: my-cluster
 spec:
   kafka:
     version: 3.3.2
     replicas: 3
     listeners:
       - name: plain
         port: 9092
         type: internal
         tls: false
       - name: tls
         port: 9093
         type: internal
         tls: true
     config:
       offsets.topic.replication.factor: 3
       transaction.state.log.replication.factor: 3
       transaction.state.log.min.isr: 2
       default.replication.factor: 3
       min.insync.replicas: 2
       inter.broker.protocol.version: '3.3'
     storage:
       type: ephemeral
   zookeeper:
     replicas: 3
     storage:
       type: ephemeral
   entityOperator:
     topicOperator: {}
     userOperator: {}
  2. 执行 kubectl apply 进行实例安装 
    #kafka-operator.yaml 为步骤1展示的内容
kubectl apply -f  kafka-operator.yaml
  3. 部署完验证 
    kubectl get po,sc,pv,pvc,secret
[root@VM-4-3-centos ~]#
NAME                                              READY   STATUS    RESTARTS      AGE
pod/my-cluster-entity-operator-54b66cffc6-vhz7b   3/3     Running   0             27h
pod/my-cluster-kafka-0                            1/1     Running   0             27h
pod/my-cluster-kafka-1                            1/1     Running   0             27h
pod/my-cluster-kafka-2                            1/1     Running   0             27h
pod/my-cluster-zookeeper-0                        1/1     Running   1 (27h ago)   27h
pod/my-cluster-zookeeper-1                        1/1     Running   0             27h
pod/my-cluster-zookeeper-2                        1/1     Running   0             27h

NAME                                            TYPE                                  DATA   AGE
secret/default-token-hmjtt                      kubernetes.io/service-account-token   3      114d
secret/demo-token-8zv4m                         kubernetes.io/service-account-token   3      23d
secret/my-cluster-clients-ca                    Opaque                                1      27h
secret/my-cluster-clients-ca-cert               Opaque                                3      27h
secret/my-cluster-cluster-ca                    Opaque                                1      27h
secret/my-cluster-cluster-ca-cert               Opaque                                3      27h
secret/my-cluster-cluster-operator-certs        Opaque                                4      27h
secret/my-cluster-entity-operator-token-vjmfh   kubernetes.io/service-account-token   3      27h
secret/my-cluster-entity-topic-operator-certs   Opaque                                4      27h
secret/my-cluster-entity-user-operator-certs    Opaque                                4      27h
secret/my-cluster-kafka-brokers                 Opaque                                12     27h
secret/my-cluster-kafka-token-m66jt             kubernetes.io/service-account-token   3      27h
secret/my-cluster-zookeeper-nodes               Opaque                                12     27h
secret/my-cluster-zookeeper-token-h7zxl         kubernetes.io/service-account-token   3      27h
  4. 删除资源
  • 删除步骤3中的资源
 kubectl delete -f kafka-operator.yaml
  • 删除此Operator
1. kubectl delete subscription <subscription-name> -n operators
2. kubectl delete clusterserviceversion -n operators
  1. 详细文档
https://github.com/chenghongxi/kubernetes-learning/blob/master/olm/kafka-operators/README.md