Add Kafka options to yorkie-cluster and missing WriteTimeout (#1149)

Add deployment template with configurable Kafka options and resolves missing write timeout settings.
yorkie-team · Feb 14, 2025 · d49a4bb · d49a4bb
1 parent 2fa676d
commit d49a4bb
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/build/charts/yorkie-cluster/templates/yorkie/deployment.yaml b/build/charts/yorkie-cluster/templates/yorkie/deployment.yaml
@@ -81,6 +81,12 @@ spec:
           "{{ .Values.yorkie.ports.profilingPort }}",
           "--backend-gateway-addr",
           "{{ .Values.yorkie.name }}-gateway.{{ .Values.yorkie.namespace }}.svc.cluster.local",
+          {{- if and .Values.yorkie.args.kafkaAddresses .Values.yorkie.args.kafkaTopic }}
+          "--kafka-addresses",
+          "{{ .Values.yorkie.args.kafkaAddresses }}",
+          "--kafka-topic",
+          "{{ .Values.yorkie.args.kafkaTopic }}",
+          {{- end }}
         ]
         ports:
           - containerPort: {{ .Values.yorkie.ports.rpcPort }}

diff --git a/cmd/yorkie/server.go b/cmd/yorkie/server.go
@@ -89,8 +89,9 @@ func newServerCmd() *cobra.Command {
 
 			if kafkaAddresses != "" && kafkaTopic != "" {
 				conf.Kafka = &messagebroker.Config{
-					Addresses: kafkaAddresses,
-					Topic:     kafkaTopic,
+					Addresses:    kafkaAddresses,
+					Topic:        kafkaTopic,
+					WriteTimeout: kafkaWriteTimeout.String(),
 				}
 			}