From d49a4bb377d40c30194c9542e3422b073194028e Mon Sep 17 00:00:00 2001
From: emplam27 <emplam27@gmail.com>
Date: Fri, 14 Feb 2025 18:40:28 +0900
Subject: [PATCH] Add Kafka options to yorkie-cluster and missing WriteTimeout
 (#1149)

Add deployment template with configurable Kafka options and resolves
missing write timeout settings.
---
 .../charts/yorkie-cluster/templates/yorkie/deployment.yaml  | 6 ++++++
 cmd/yorkie/server.go                                        | 5 +++--
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/build/charts/yorkie-cluster/templates/yorkie/deployment.yaml b/build/charts/yorkie-cluster/templates/yorkie/deployment.yaml
index 3c7bc50fd..dcbba5eb1 100644
--- 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
index 3708ec91c..04362600b 100644
--- 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(),
 				}
 			}