diff --git a/kafka/kafka.yaml b/kafka/kafka.yaml new file mode 100644 index 0000000..0d8cf04 --- /dev/null +++ b/kafka/kafka.yaml @@ -0,0 +1,96 @@ +apiVersion: apps/v1 +kind: StatefulSet +metadata: + namespace: mall + name: kafka + labels: + mall: kafka +spec: + replicas: 1 + selector: + matchLabels: + mall: kafka + serviceName: kafka-svc + template: + metadata: + namespace: mall + name: kafka + labels: + mall: kafka + spec: + imagePullSecrets: + - name: abahub-registry-secret + containers: + - name: kafka + env: + - name: KAFKA_CFG_NODE_ID + value: "1" + - name: ALLOW_PLAINTEXT_LISTENER + value: "yes" + - name: KAFKA_HEAP_OPTS + value: "-Xmx512m -Xmx512m" + - name: KAFKA_ENABLE_KRAFT + value: "yes" + - name: KAFKA_CFG_PROCESS_ROLES + value: "broker,controller" + - name: KAFKA_KRAFT_CLUSTER_ID + value: "F8iYYhRDSMKDWDiY9tYCy1" + - name: KAFKA_CFG_CONTROLLER_LISTENER_NAMES + value: "CONTROLLER" + - name: KAFKA_CFG_INTER_BROKER_LISTENER_NAME + value: "BROKER" + - name: KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP + value: "CONTROLLER:PLAINTEXT,BROKER:PLAINTEXT" + - name: KAFKA_CFG_LISTENERS + value: "BROKER://:9092,CONTROLLER://:9093" + - name: KAFKA_CFG_ADVERTISED_LISTENERS + value: "BROKER://kafka-svc.mall.svc.cluster.local:9092" + - name: KAFKA_CFG_CONTROLLER_QUORUM_VOTERS + value: "1@kafka-svc.mall.svc.cluster.local:9093" + image: abahub.abacus.com.cn/base/bitnami/kafka:3.9.0 + imagePullPolicy: IfNotPresent + ports: + - containerPort: 9092 + - containerPort: 9093 + volumeMounts: + - mountPath: /bitnami/kafka + name: kafkadata + resources: + limits: + cpu: 1000m + memory: 800Mi + requests: + cpu: 300m + memory: 800Mi + volumeClaimTemplates: + - metadata: + namespace: mall + name: kafkadata + annotations: + nfs.io/storage-path: kafkadata + spec: + accessModes: + - ReadWriteMany + resources: + requests: + storage: 2Gi + storageClassName: nfs-retain +--- +apiVersion: v1 +kind: Service +metadata: + namespace: mall + name: kafka-svc + annotations: + lb.kubesphere.io/v1alpha1: openelb +spec: + selector: + mall: kafka + ports: + - name: kafka-svcport + port: 9092 + targetPort: 9092 + - name: kafka-kraftport + port: 9093 + targetPort: 9093 + clusterIP: None \ No newline at end of file