Skip to content

Commit 53587da

Browse files
EamonZhangEamonZhang
committed
2 parents cad544e + 44f06b0 commit 53587da

67 files changed

Lines changed: 7448 additions & 54 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎addons/index.yaml‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,8 @@ entries:
6363
kvrocks:
6464
- version: 2.8
6565
description: "Apache Kvrocks is a distributed key value NoSQL database that uses RocksDB as storage engine and is compatible with Redis protocol."
66+
- version: "2.10"
67+
description: "Apache Kvrocks is a distributed key value NoSQL database that uses RocksDB as storage engine and is compatible with Redis protocol."
6668
yugabytedb:
6769
- version: 2024
6870
description: "YugabyteDB is a high-performance distributed SQL database for powering global, internet-scale applications. "

‎addons/kafka/3.6/meta.yaml‎

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,15 +24,36 @@ allow_parameters:
2424
- name: "controller.extraConfig"
2525
required: false
2626
description: "controller.extraConfig config for values.yaml"
27+
- name: "controller.replicaCount"
28+
required: false
29+
description: "controller.replicaCount config for values.yaml"
30+
- name: "controller.controllerOnly"
31+
required: false
32+
description: "controller.controllerOnly config for values.yaml"
33+
- name: "controller.zookeeperMigrationMode"
34+
required: false
35+
description: "controller.zookeeperMigrationMode config for values.yaml"
2736
- name: "controller.nodeSelector"
2837
required: false
2938
description: "controller.nodeSelector config for values.yaml"
39+
- name: "controller.persistence"
40+
required: false
41+
description: "controller.persistence config for values.yaml"
42+
- name: "broker.replicaCount"
43+
required: false
44+
description: "broker.replicaCount config for values.yaml"
45+
- name: "broker.zookeeperMigrationMode"
46+
required: false
47+
description: "broker.zookeeperMigrationMode config for values.yaml"
3048
- name: "broker.extraConfig"
3149
required: false
3250
description: "broker.extraConfig config for values.yaml"
3351
- name: "broker.nodeSelector"
3452
required: false
3553
description: "broker.nodeSelector config for values.yaml"
54+
- name: "broker.persistence"
55+
required: false
56+
description: "broker.persistence config for values.yaml"
3657
- name: "listeners.client.protocol"
3758
required: false
3859
description: "listeners client protocol config for values.yaml"
@@ -60,6 +81,9 @@ allow_parameters:
6081
- name: "listeners.advertisedListeners"
6182
required: false
6283
description: "listeners advertisedListeners or not config for values.yaml"
84+
- name: "kraft.enabled"
85+
required: false
86+
description: "kraft enabled or not config for values.yaml"
6387
- name: "metrics.jmx.enabled"
6488
required: false
6589
description: "metrics jmx enabled or not config for values.yaml"
@@ -69,4 +93,10 @@ allow_parameters:
6993
- name: "metrics.kafka.enabled"
7094
required: false
7195
description: "metrics kafka enabled or not config for values.yaml"
96+
- name: "externalZookeeper"
97+
required: false
98+
description: "externalZookeeper config for values.yaml"
99+
- name: "zookeeperChrootPath"
100+
required: false
101+
description: "zookeeperChrootPath config for values.yaml"
72102
archive: false

‎addons/kafka/3.6/plans/standard-16c32g3w/bind.yaml‎

Lines changed: 44 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
{{- $releaseNamespace := .Release.Namespace }}
2+
{{- $clusterDomain := .Values.clusterDomain }}
3+
{{- $fullname := include "common.names.fullname" . }}
4+
{{- $clientPort := int .Values.listeners.client.containerPort }}
15
credential:
26
- name: PROTOCOL_MAP
37
value: {{ include "kafka.securityProtocolMap" . }}
@@ -23,27 +27,44 @@ credential:
2327
serviceRef:
2428
name: {{ template "common.names.fullname" . }}
2529
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
26-
{{- end }}
2730

28-
{{- if .Values.externalAccess.enabled }}
2931
- name: EXTERNAL_CLIENT_PORT
3032
valueFrom:
3133
serviceRef:
3234
name: {{ template "common.names.fullname" . }}
3335
jsonpath: '{ .spec.ports[?(@.name=="tcp-external")].port }'
3436
{{- end }}
3537

36-
37-
{{- range $i, $internelListeners := ( splitList "," ( include "kafka.kraft.internelListeners" . ) )}}
38+
{{- $brokerList := list }}
39+
{{- if or (not .Values.kraft.enabled) (.Values.controller.controllerOnly) }}
40+
{{- range $i := until (int .Values.broker.replicaCount) }}
41+
{{- $brokerList = append $brokerList (printf "%s-broker-%d.%s-broker-headless.%s.svc.%s" $fullname $i $fullname $releaseNamespace $clusterDomain ) }}
42+
{{- end }}
43+
{{- else }}
44+
{{- range $i := until (int .Values.controller.replicaCount) }}
45+
{{- $brokerList = append $brokerList (printf "%s-controller-%d.%s-controller-headless.%s.svc.%s" $fullname $i $fullname $releaseNamespace $clusterDomain ) }}
46+
{{- end }}
47+
{{- end }}
48+
{{- range $i, $broker := ( $brokerList )}}
3849
- name: {{ printf "KAFKA_NODE_%d" $i }}
39-
value: {{ $internelListeners }}
50+
value: {{ $broker }}
4051
{{- end }}
4152

42-
- name: KAFKA_PORT
53+
{{- $replicaCount := int .Values.broker.replicaCount }}
54+
{{- if gt $replicaCount 0 }}
55+
- name: KAFKA_NODE_PORT
4356
valueFrom:
4457
serviceRef:
45-
name: {{ template "common.names.fullname" . }}
58+
name: {{ printf "%s-broker-headless" (include "common.names.fullname" .) | trunc 63 | trimSuffix "-" }}
4659
jsonpath: '{ .spec.ports[?(@.name=="tcp-client")].port }'
60+
{{- else }}
61+
- name: KAFKA_NODE_PORT
62+
valueFrom:
63+
serviceRef:
64+
name: {{ printf "%s-controller-headless" (include "common.names.fullname" .) | trunc 63 | trimSuffix "-" }}
65+
jsonpath: '{ .spec.ports[?(@.name=="tcp-client")].port }'
66+
{{- end }}
67+
4768

4869
{{- if (include "kafka.saslUserPasswordsEnabled" .) }}
4970
{{- if (include "kafka.client.saslEnabled" .) }}
@@ -75,8 +96,21 @@ credential:
7596
{{- end }}
7697
{{- end }}
7798

99+
78100
{{- if .Values.externalAccess.enabled }}
79-
{{- $fullname := include "common.names.fullname" . }}
101+
{{- if or (not .Values.kraft.enabled) (.Values.controller.controllerOnly) }}
102+
{{- $replicaCount := .Values.broker.replicaCount | int }}
103+
{{- range $i := until $replicaCount }}
104+
- name: {{ printf "EXTERNAL_KAFKA_NODE_%d" $i }}
105+
valueFrom:
106+
serviceRef:
107+
name: {{ printf "%s-broker-%d-external" (include "common.names.fullname" $) $i | trunc 63 | trimSuffix "-" }}
108+
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
109+
{{- end }}
110+
111+
- name: EXTERNAL_KAFKA_NODE_PORT
112+
value: {{ .Values.externalAccess.broker.service.ports.external }}
113+
{{- else }}
80114
{{- $replicaCount := .Values.controller.replicaCount | int }}
81115
{{- range $i := until $replicaCount }}
82116
- name: {{ printf "EXTERNAL_KAFKA_NODE_%d" $i }}
@@ -86,6 +120,7 @@ credential:
86120
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
87121
{{- end }}
88122

89-
- name: EXTERNAL_KAFKA_PORT
123+
- name: EXTERNAL_KAFKA_NODE_PORT
90124
value: {{ .Values.externalAccess.controller.service.ports.external }}
125+
{{- end }}
91126
{{- end }}

‎addons/kafka/3.6/plans/standard-1c2g3w/bind.yaml‎

Lines changed: 44 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
{{- $releaseNamespace := .Release.Namespace }}
2+
{{- $clusterDomain := .Values.clusterDomain }}
3+
{{- $fullname := include "common.names.fullname" . }}
4+
{{- $clientPort := int .Values.listeners.client.containerPort }}
15
credential:
26
- name: PROTOCOL_MAP
37
value: {{ include "kafka.securityProtocolMap" . }}
@@ -23,27 +27,44 @@ credential:
2327
serviceRef:
2428
name: {{ template "common.names.fullname" . }}
2529
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
26-
{{- end }}
2730

28-
{{- if .Values.externalAccess.enabled }}
2931
- name: EXTERNAL_CLIENT_PORT
3032
valueFrom:
3133
serviceRef:
3234
name: {{ template "common.names.fullname" . }}
3335
jsonpath: '{ .spec.ports[?(@.name=="tcp-external")].port }'
3436
{{- end }}
3537

36-
37-
{{- range $i, $internelListeners := ( splitList "," ( include "kafka.kraft.internelListeners" . ) )}}
38+
{{- $brokerList := list }}
39+
{{- if or (not .Values.kraft.enabled) (.Values.controller.controllerOnly) }}
40+
{{- range $i := until (int .Values.broker.replicaCount) }}
41+
{{- $brokerList = append $brokerList (printf "%s-broker-%d.%s-broker-headless.%s.svc.%s" $fullname $i $fullname $releaseNamespace $clusterDomain ) }}
42+
{{- end }}
43+
{{- else }}
44+
{{- range $i := until (int .Values.controller.replicaCount) }}
45+
{{- $brokerList = append $brokerList (printf "%s-controller-%d.%s-controller-headless.%s.svc.%s" $fullname $i $fullname $releaseNamespace $clusterDomain ) }}
46+
{{- end }}
47+
{{- end }}
48+
{{- range $i, $broker := ( $brokerList )}}
3849
- name: {{ printf "KAFKA_NODE_%d" $i }}
39-
value: {{ $internelListeners }}
50+
value: {{ $broker }}
4051
{{- end }}
4152

42-
- name: KAFKA_PORT
53+
{{- $replicaCount := int .Values.broker.replicaCount }}
54+
{{- if gt $replicaCount 0 }}
55+
- name: KAFKA_NODE_PORT
4356
valueFrom:
4457
serviceRef:
45-
name: {{ template "common.names.fullname" . }}
58+
name: {{ printf "%s-broker-headless" (include "common.names.fullname" .) | trunc 63 | trimSuffix "-" }}
4659
jsonpath: '{ .spec.ports[?(@.name=="tcp-client")].port }'
60+
{{- else }}
61+
- name: KAFKA_NODE_PORT
62+
valueFrom:
63+
serviceRef:
64+
name: {{ printf "%s-controller-headless" (include "common.names.fullname" .) | trunc 63 | trimSuffix "-" }}
65+
jsonpath: '{ .spec.ports[?(@.name=="tcp-client")].port }'
66+
{{- end }}
67+
4768

4869
{{- if (include "kafka.saslUserPasswordsEnabled" .) }}
4970
{{- if (include "kafka.client.saslEnabled" .) }}
@@ -75,8 +96,21 @@ credential:
7596
{{- end }}
7697
{{- end }}
7798

99+
78100
{{- if .Values.externalAccess.enabled }}
79-
{{- $fullname := include "common.names.fullname" . }}
101+
{{- if or (not .Values.kraft.enabled) (.Values.controller.controllerOnly) }}
102+
{{- $replicaCount := .Values.broker.replicaCount | int }}
103+
{{- range $i := until $replicaCount }}
104+
- name: {{ printf "EXTERNAL_KAFKA_NODE_%d" $i }}
105+
valueFrom:
106+
serviceRef:
107+
name: {{ printf "%s-broker-%d-external" (include "common.names.fullname" $) $i | trunc 63 | trimSuffix "-" }}
108+
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
109+
{{- end }}
110+
111+
- name: EXTERNAL_KAFKA_NODE_PORT
112+
value: {{ .Values.externalAccess.broker.service.ports.external }}
113+
{{- else }}
80114
{{- $replicaCount := .Values.controller.replicaCount | int }}
81115
{{- range $i := until $replicaCount }}
82116
- name: {{ printf "EXTERNAL_KAFKA_NODE_%d" $i }}
@@ -86,6 +120,7 @@ credential:
86120
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
87121
{{- end }}
88122

89-
- name: EXTERNAL_KAFKA_PORT
123+
- name: EXTERNAL_KAFKA_NODE_PORT
90124
value: {{ .Values.externalAccess.controller.service.ports.external }}
125+
{{- end }}
91126
{{- end }}

‎addons/kafka/3.6/plans/standard-24c64g3w/bind.yaml‎

Lines changed: 44 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
{{- $releaseNamespace := .Release.Namespace }}
2+
{{- $clusterDomain := .Values.clusterDomain }}
3+
{{- $fullname := include "common.names.fullname" . }}
4+
{{- $clientPort := int .Values.listeners.client.containerPort }}
15
credential:
26
- name: PROTOCOL_MAP
37
value: {{ include "kafka.securityProtocolMap" . }}
@@ -23,27 +27,44 @@ credential:
2327
serviceRef:
2428
name: {{ template "common.names.fullname" . }}
2529
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
26-
{{- end }}
2730

28-
{{- if .Values.externalAccess.enabled }}
2931
- name: EXTERNAL_CLIENT_PORT
3032
valueFrom:
3133
serviceRef:
3234
name: {{ template "common.names.fullname" . }}
3335
jsonpath: '{ .spec.ports[?(@.name=="tcp-external")].port }'
3436
{{- end }}
3537

36-
37-
{{- range $i, $internelListeners := ( splitList "," ( include "kafka.kraft.internelListeners" . ) )}}
38+
{{- $brokerList := list }}
39+
{{- if or (not .Values.kraft.enabled) (.Values.controller.controllerOnly) }}
40+
{{- range $i := until (int .Values.broker.replicaCount) }}
41+
{{- $brokerList = append $brokerList (printf "%s-broker-%d.%s-broker-headless.%s.svc.%s" $fullname $i $fullname $releaseNamespace $clusterDomain ) }}
42+
{{- end }}
43+
{{- else }}
44+
{{- range $i := until (int .Values.controller.replicaCount) }}
45+
{{- $brokerList = append $brokerList (printf "%s-controller-%d.%s-controller-headless.%s.svc.%s" $fullname $i $fullname $releaseNamespace $clusterDomain ) }}
46+
{{- end }}
47+
{{- end }}
48+
{{- range $i, $broker := ( $brokerList )}}
3849
- name: {{ printf "KAFKA_NODE_%d" $i }}
39-
value: {{ $internelListeners }}
50+
value: {{ $broker }}
4051
{{- end }}
4152

42-
- name: KAFKA_PORT
53+
{{- $replicaCount := int .Values.broker.replicaCount }}
54+
{{- if gt $replicaCount 0 }}
55+
- name: KAFKA_NODE_PORT
4356
valueFrom:
4457
serviceRef:
45-
name: {{ template "common.names.fullname" . }}
58+
name: {{ printf "%s-broker-headless" (include "common.names.fullname" .) | trunc 63 | trimSuffix "-" }}
4659
jsonpath: '{ .spec.ports[?(@.name=="tcp-client")].port }'
60+
{{- else }}
61+
- name: KAFKA_NODE_PORT
62+
valueFrom:
63+
serviceRef:
64+
name: {{ printf "%s-controller-headless" (include "common.names.fullname" .) | trunc 63 | trimSuffix "-" }}
65+
jsonpath: '{ .spec.ports[?(@.name=="tcp-client")].port }'
66+
{{- end }}
67+
4768

4869
{{- if (include "kafka.saslUserPasswordsEnabled" .) }}
4970
{{- if (include "kafka.client.saslEnabled" .) }}
@@ -75,8 +96,21 @@ credential:
7596
{{- end }}
7697
{{- end }}
7798

99+
78100
{{- if .Values.externalAccess.enabled }}
79-
{{- $fullname := include "common.names.fullname" . }}
101+
{{- if or (not .Values.kraft.enabled) (.Values.controller.controllerOnly) }}
102+
{{- $replicaCount := .Values.broker.replicaCount | int }}
103+
{{- range $i := until $replicaCount }}
104+
- name: {{ printf "EXTERNAL_KAFKA_NODE_%d" $i }}
105+
valueFrom:
106+
serviceRef:
107+
name: {{ printf "%s-broker-%d-external" (include "common.names.fullname" $) $i | trunc 63 | trimSuffix "-" }}
108+
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
109+
{{- end }}
110+
111+
- name: EXTERNAL_KAFKA_NODE_PORT
112+
value: {{ .Values.externalAccess.broker.service.ports.external }}
113+
{{- else }}
80114
{{- $replicaCount := .Values.controller.replicaCount | int }}
81115
{{- range $i := until $replicaCount }}
82116
- name: {{ printf "EXTERNAL_KAFKA_NODE_%d" $i }}
@@ -86,6 +120,7 @@ credential:
86120
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
87121
{{- end }}
88122

89-
- name: EXTERNAL_KAFKA_PORT
123+
- name: EXTERNAL_KAFKA_NODE_PORT
90124
value: {{ .Values.externalAccess.controller.service.ports.external }}
125+
{{- end }}
91126
{{- end }}

0 commit comments

Comments
 (0)