kafka-cluster

This commit is contained in:
ychangkim
2025-12-02 14:03:48 +09:00
parent 257c6915f1
commit e385ec8130
7 changed files with 3 additions and 20 deletions
@@ -1,4 +1,3 @@
{{- if .Values.kafkaConnect.enabled }}
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
@@ -22,7 +21,6 @@ spec:
value.converter: org.apache.kafka.connect.json.JsonConverter
plugin.path: /opt/kafka/plugins
topic.creation.enable: "true"
{{- if .Values.oauth.enabled }}
authentication:
type: oauth
tokenEndpointUri: {{ .Values.oauth.keycloakUrl }}/realms/{{ .Values.oauth.keycloakRealm }}/protocol/openid-connect/token
@@ -33,7 +31,6 @@ spec:
tlsTrustedCertificates:
- secretName: {{ .Values.oauth.tlsSecretName }}
pattern: {{ .Values.oauth.tlsCertificate | quote }}
{{- end }}
template:
connectContainer:
volumeMounts:
@@ -49,5 +46,4 @@ spec:
logging:
type: inline
loggers:
rootLogger.level: {{ .Values.logging.connect.rootLoggerLevel }}
{{- end }}
rootLogger.level: {{ .Values.logging.connect.rootLoggerLevel }}
@@ -1,5 +1,3 @@
{{- if .Values.kafkaConnect.enabled }}
---
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaTopic
metadata:
@@ -49,5 +47,4 @@ spec:
config:
cleanup.policy: {{ .Values.connectTopics.config.cleanupPolicy }}
retention.ms: {{ .Values.connectTopics.config.retentionMs }}
segment.bytes: {{ .Values.connectTopics.config.segmentBytes }}
{{- end }}
segment.bytes: {{ .Values.connectTopics.config.segmentBytes }}
@@ -1,4 +1,3 @@
{{- if .Values.kafkaConnect.enabled }}
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaUser
metadata:
@@ -27,5 +26,4 @@ spec:
operations:
- Read
- Write
- Describe
{{- end }}
- Describe
@@ -22,7 +22,6 @@ spec:
type: cluster-ip
port: {{ .Values.listener.port }}
tls: {{ .Values.listener.tls }}
{{- if .Values.oauth.enabled }}
authentication:
type: oauth
clientId: {{ .Values.oauth.keycloakClientId | quote }}
@@ -41,7 +40,6 @@ spec:
tlsTrustedCertificates:
- secretName: {{ .Values.oauth.tlsSecretName }}
certificate: {{ .Values.oauth.tlsCertificate }}
{{- end }}
config:
offsets.topic.replication.factor: {{ .Values.config.offsetsTopicReplicationFactor }}
transaction.state.log.replication.factor: {{ .Values.config.transactionStateLogReplicationFactor }}