Skip to content

Commit 77a34fe

Browse files
committed
Fix CI
1 parent 55f4deb commit 77a34fe

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/ctl/namespace/set_replication_clusters.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ func setReplicationClusters(vc *cmdutils.VerbCmd) {
8787

8888
vc.FlagSetGroup.InFlagSet("Namespaces", func(flagSet *pflag.FlagSet) {
8989
flagSet.StringVarP(
90-
&data.ClusterIds,
90+
&data.ClusterIDs,
9191
"clusters",
9292
"c",
9393
"",
@@ -102,7 +102,7 @@ func doSetReplicationClusters(vc *cmdutils.VerbCmd, data utils.NamespacesData) e
102102
ns := vc.NameArg
103103
admin := cmdutils.NewPulsarClient()
104104

105-
clusters := strings.Split(data.ClusterIds, ",")
105+
clusters := strings.Split(data.ClusterIDs, ",")
106106
err := admin.Namespaces().SetNamespaceReplicationClusters(ns, clusters)
107107
if err == nil {
108108
vc.Command.Printf("Set replication clusters successfully for %s\n", ns)

0 commit comments

Comments
 (0)