Bootstrap kafka config for worker service (#6512)

cadence-workflow · Nov 21, 2024 · 7c70765 · 7c70765
1 parent 925e64d
commit 7c70765
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/service/worker/service.go b/service/worker/service.go
@@ -150,6 +150,7 @@ func NewConfig(params *resource.Params) *Config {
 			},
 			MaxWorkflowRetentionInDays: dc.GetIntProperty(dynamicconfig.MaxRetentionDays),
 		},
+		KafkaCfg: params.KafkaConfig,
 		BatcherCfg: &batcher.Config{
 			AdminOperationToken: dc.GetStringProperty(dynamicconfig.AdminOperationToken),
 			ClusterMetadata:     params.ClusterMetadata,