Fix to set default value of metadata database

toga4 · Jan 8, 2023 · b348e18 · b348e18
1 parent 462659e
commit b348e18
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cmd/spream/main.go b/cmd/spream/main.go
@@ -62,7 +62,7 @@ Options:
 
 	fs.StringVar(&flags.database, "database", "", "")
 	fs.StringVar(&flags.streamName, "stream", "", "")
-	fs.StringVar(&flags.metadataTableName, "metadata-table", flags.database, "")
+	fs.StringVar(&flags.metadataTableName, "metadata-table", "", "")
 	fs.StringVar(&flags.metadataDatabase, "metadata-database", flags.database, "")
 	fs.DurationVar(&flags.heartbeatInterval, "heartbeat-interval", 10*time.Second, "")
 
@@ -79,6 +79,9 @@ Options:
 		fs.Usage()
 		return nil, errors.New("database and stream is required")
 	}
+	if flags.metadataDatabase == "" {
+		flags.metadataDatabase = flags.database
+	}
 
 	if start != "" {
 		t, err := time.Parse(time.RFC3339, start)