From 06bbf5f67e2a7ab8e5694a70eaf4dbeb7171efdd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jean-No=C3=ABl=20Moyne?= Date: Mon, 18 Sep 2023 21:32:45 -0700 Subject: [PATCH] Changes the KV bucket sourcing code to use the SubjectTransforms array --- kv.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/kv.go b/kv.go index fc3e4a506..7382f4d87 100644 --- a/kv.go +++ b/kv.go @@ -442,8 +442,7 @@ func (js *js) CreateKeyValue(cfg *KeyValueConfig) (KeyValue, error) { } if ss.External == nil || sourceBucketName != cfg.Bucket { - ss.FilterSubject = fmt.Sprintf(kvSubjectsTmpl, sourceBucketName) - ss.SubjectTransformDest = fmt.Sprintf(kvSubjectsTmpl, cfg.Bucket) + ss.SubjectTransforms = []SubjectTransformConfig{{Source: fmt.Sprintf(kvSubjectsTmpl, sourceBucketName), Destination: fmt.Sprintf(kvSubjectsTmpl, cfg.Bucket)}} } scfg.Sources = append(scfg.Sources, ss) }