fix(broker): produce correct topics.json and subscription.json when broker scaling
diff --git a/pkg/controller/broker/broker_controller.go b/pkg/controller/broker/broker_controller.go
index d40a37c..aabe517 100644
--- a/pkg/controller/broker/broker_controller.go
+++ b/pkg/controller/broker/broker_controller.go
@@ -259,7 +259,8 @@
subscriptionGroupCommand := getCopyMetadataJsonCommand(cons.SubscriptionGroupJsonDir, sourcePodName, broker.Namespace, k8s)
log.Info("subscriptionGroupCommand: " + subscriptionGroupCommand)
MakeConfigDirCommand := "mkdir -p " + cons.StoreConfigDir
- ChmodDirCommand := "chmod a+rw -R " + cons.StoreConfigDir
+ ChmodDirCommand := "chmod a+rw " + cons.StoreConfigDir
+ log.Info("ChmodDirCommand: " + ChmodDirCommand)
cmd = []string{"/bin/bash", "-c", MakeConfigDirCommand + " && " + ChmodDirCommand + " && " + topicsCommand + " && " + subscriptionGroupCommand}
}
}
@@ -327,10 +328,11 @@
}
func buildOutputCommand(content string, dest string) []string {
+ replaced := strings.Replace(content,"\"","\\\"", -1)
cmdOpts := []string{
"echo",
"-e",
- "\"" + content + "\"",
+ "\"" + replaced + "\"",
">",
dest,
}
