chore: support parameters api for kafka (#1369)

addons/kafka/templates/_helpers.tpl

@@ -138,17 +138,46 @@ Define kafka-broker component definition regex pattern
 {{/*
 Define kafka config constraint name
 */}}
-{{- define "kafka.configConstraintName" -}}
+{{- define "kafka.paramsDefName" -}}
 kafka-config-constraints
 {{- end -}}
 
 {{/*
 Define kafka config constraint name
 */}}
-{{- define "kafka2.configConstraintName" -}}
+{{- define "kafka2.paramsDefName" -}}
 kafka2-config-constraints
 {{- end -}}
 
+{{/*
+Define kafka parameter config renderer name
+*/}}
+{{- define "kafka.brokerPCRName" -}}
+kafka-broker-pcr
+{{- end -}}
+
+{{/*
+Define kafka parameter config renderer name
+*/}}
+{{- define "kafka.combinePCRName" -}}
+kafka-combine-pcr
+{{- end -}}
+
+{{/*
+Define kafka parameter config renderer name
+*/}}
+{{- define "kafka.controllerPCRName" -}}
+kafka-controller-pcr
+{{- end -}}
+
+{{/*
+Define kafka parameter config renderer name
+*/}}
+{{- define "kafka2.brokerPCRName" -}}
+kafka2-broker-pcr
+{{- end -}}
+
+
 {{/*
 Define kafka configuration tpl name
 */}}

addons/kafka/templates/cmpd-broker-27.yaml

@@ -84,7 +84,6 @@ spec:
   updateStrategy: BestEffortParallel
   configs:
     - name: kafka-configuration-tpl
-      constraintRef: {{ include "kafka2.configConstraintName" . }}
       templateRef: {{ include "kafka2.configurationTplName" . }}
       volumeName: kafka-config
       namespace: {{ .Release.Namespace }}

addons/kafka/templates/cmpd-broker.yaml

@@ -80,7 +80,6 @@ spec:
   updateStrategy: BestEffortParallel
   configs:
     - name: kafka-configuration-tpl
-      constraintRef: {{ include "kafka.configConstraintName" . }}
       templateRef: {{ include "kafka.configurationTplName" . }}
       volumeName: kafka-config
       namespace: {{ .Release.Namespace }}

addons/kafka/templates/cmpd-combine.yaml

@@ -71,7 +71,6 @@ spec:
   updateStrategy: BestEffortParallel
   configs:
     - name: kafka-configuration-tpl
-      constraintRef: {{ include "kafka.configConstraintName" . }}
       templateRef: {{ include "kafka.configurationTplName" . }}
       volumeName: kafka-config
       namespace: {{ .Release.Namespace }}

addons/kafka/templates/cmpd-controller.yaml

@@ -46,7 +46,6 @@ spec:
   updateStrategy: BestEffortParallel
   configs:
     - name: kafka-configuration-tpl
-      constraintRef: {{ include "kafka.configConstraintName" . }}
       templateRef: {{ include "kafka.configurationTplName" . }}
       volumeName: kafka-config
       namespace: {{ .Release.Namespace }}

addons/kafka/templates/paramsdef.yaml

@@ -0,0 +1,20 @@
+apiVersion: parameters.kubeblocks.io/v1alpha1
+kind: ParametersDefinition
+metadata:
+  name: {{ include "kafka.paramsDefName" . }}
+  labels:
+    {{- include "kafka.labels" . | nindent 4 }}
+    {{- if .Values.commonLabels }}
+    {{- include "common.tplvalues.render" ( dict "value" .Values.commonLabels "context" $ ) | nindent 4 }}
+    {{- end }}
+  {{- if .Values.commonAnnotations }}
+  annotations: {{- include "common.tplvalues.render" ( dict "value" .Values.commonAnnotations "context" $ ) | nindent 4 }}
+  {{- end }}
+spec:
+  fileName: server.properties
+  parametersSchema:
+    # top level mysql configuration type
+    topLevelKey: KafkaParameter
+    # schemaInJSON: auto generate from cue scripts
+    cue: |-
+      {{- .Files.Get "configs/kafka-server-constraint.cue" | nindent 6 }}

addons/kafka/templates/paramsdef2.yaml

@@ -0,0 +1,20 @@
+apiVersion: parameters.kubeblocks.io/v1alpha1
+kind: ParametersDefinition
+metadata:
+  name: {{ include "kafka2.paramsDefName" . }}
+  labels:
+    {{- include "kafka.labels" . | nindent 4 }}
+    {{- if .Values.commonLabels }}
+    {{- include "common.tplvalues.render" ( dict "value" .Values.commonLabels "context" $ ) | nindent 4 }}
+    {{- end }}
+  {{- if .Values.commonAnnotations }}
+  annotations: {{- include "common.tplvalues.render" ( dict "value" .Values.commonAnnotations "context" $ ) | nindent 4 }}
+  {{- end }}
+spec:
+  fileName: server.properties
+  parametersSchema:
+    # top level mysql configuration type
+    topLevelKey: KafkaParameter
+    # schemaInJSON: auto generate from cue scripts
+    cue: |-
+      {{- .Files.Get "configs/2.7/kafka-27-server-constraint.cue" | nindent 6 }}

addons/kafka/templates/pcr-broker.yaml

@@ -0,0 +1,14 @@
+apiVersion: parameters.kubeblocks.io/v1alpha1
+kind: ParamConfigRenderer
+metadata:
+  name: {{ include "kafka.brokerPCRName" . }}
+  labels:
+    {{- include "kafka.labels" . | nindent 4 }}
+spec:
+  componentDef: {{ include "kafka-broker.componentDefName" . }}
+  parametersDefs:
+    - {{ include "kafka.paramsDefName" . }}
+  configs:
+    - name: server.properties
+      fileFormatConfig:
+        format: properties

addons/kafka/templates/pcr-broker2.yaml

@@ -0,0 +1,14 @@
+apiVersion: parameters.kubeblocks.io/v1alpha1
+kind: ParamConfigRenderer
+metadata:
+  name: {{ include "kafka2.brokerPCRName" . }}
+  labels:
+    {{- include "kafka.labels" . | nindent 4 }}
+spec:
+  componentDef: {{ include "kafka2-broker.componentDefName" . }}
+  parametersDefs:
+    - {{ include "kafka2.paramsDefName" . }}
+  configs:
+    - name: server.properties
+      fileFormatConfig:
+        format: properties

addons/kafka/templates/pcr-combine.yaml

@@ -0,0 +1,14 @@
+apiVersion: parameters.kubeblocks.io/v1alpha1
+kind: ParamConfigRenderer
+metadata:
+  name: {{ include "kafka.combinePCRName" . }}
+  labels:
+    {{- include "kafka.labels" . | nindent 4 }}
+spec:
+  componentDef: {{ include "kafka-combine.componentDefName" . }}
+  parametersDefs:
+    - {{ include "kafka.paramsDefName" . }}
+  configs:
+    - name: server.properties
+      fileFormatConfig:
+        format: properties

addons/kafka/templates/pcr-controller.yaml

@@ -0,0 +1,14 @@
+apiVersion: parameters.kubeblocks.io/v1alpha1
+kind: ParamConfigRenderer
+metadata:
+  name: {{ include "kafka.controllerPCRName" . }}
+  labels:
+    {{- include "kafka.labels" . | nindent 4 }}
+spec:
+  componentDef: {{ include "kafka-controller.componentDefName" . }}
+  parametersDefs:
+    - {{ include "kafka.paramsDefName" . }}
+  configs:
+    - name: server.properties
+      fileFormatConfig:
+        format: properties