|
@@ -2,42 +2,33 @@ apiVersion: v1
|
|
|
kind: Service
|
|
|
metadata:
|
|
|
name: kafka-svc
|
|
|
- namespace: [ENV]
|
|
|
+ namespace: qa
|
|
|
labels:
|
|
|
app: kafka
|
|
|
spec:
|
|
|
- type: ClusterIP
|
|
|
- clusterIP: None
|
|
|
ports:
|
|
|
- - name: kafka
|
|
|
- port: 9093
|
|
|
- targetPort: kafka
|
|
|
+ - port: 9093
|
|
|
+ name: server
|
|
|
+ clusterIP: None #创建无头服务,如果需要对外暴露端口可自行创建service
|
|
|
selector:
|
|
|
app: kafka
|
|
|
---
|
|
|
-apiVersion: v1
|
|
|
-kind: Service
|
|
|
+apiVersion: policy/v1beta1
|
|
|
+kind: PodDisruptionBudget
|
|
|
metadata:
|
|
|
- name: kafka
|
|
|
- namespace: [ENV]
|
|
|
- labels:
|
|
|
- app: kafka
|
|
|
+ name: kafka-pdb
|
|
|
+ namespace: qa
|
|
|
spec:
|
|
|
- type: ClusterIP
|
|
|
- ports:
|
|
|
- - name: kafka
|
|
|
- port: 9093
|
|
|
- targetPort: kafka
|
|
|
selector:
|
|
|
- app: kafka
|
|
|
+ matchLabels:
|
|
|
+ app: kafka
|
|
|
+ minAvailable: 2
|
|
|
---
|
|
|
apiVersion: apps/v1
|
|
|
kind: StatefulSet
|
|
|
metadata:
|
|
|
- namespace: [ENV]
|
|
|
name: kafka
|
|
|
- labels:
|
|
|
- app: kafka
|
|
|
+ namespace: qa
|
|
|
spec:
|
|
|
selector:
|
|
|
matchLabels:
|
|
@@ -92,7 +83,7 @@ spec:
|
|
|
fieldRef:
|
|
|
fieldPath: metadata.name
|
|
|
- name: KAFKA_CFG_ZOOKEEPER_CONNECT
|
|
|
- value: "zk-cs.[ENV].svc.cluster.local:2181"
|
|
|
+ value: "zk-cs.qa.svc.cluster.local:2181"
|
|
|
- name: KAFKA_PORT_NUMBER
|
|
|
value: "9093"
|
|
|
- name: KAFKA_CFG_LISTENERS
|