Fix kafka write timeout error

yorkie-team · Feb 13, 2025 · 5f16ef1 · 5f16ef1
1 parent 7ff0767
commit 5f16ef1
Showing 1 changed file with 3 additions and 2 deletions.
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(),
 				}
 			}