Update kafka-postgres -> kafka-redis config

Author: jakeloo

cmd/root.go

@@ -131,14 +131,10 @@ func init() {
 	rootCmd.PersistentFlags().String("storage-main-kafka-username", "", "Kafka username for main storage")
 	rootCmd.PersistentFlags().String("storage-main-kafka-password", "", "Kafka password for main storage")
 	rootCmd.PersistentFlags().Bool("storage-main-kafka-enable-tls", true, "Enable TLS for Kafka connection in main storage")
-	rootCmd.PersistentFlags().String("storage-main-kafka-postgres-host", "", "PostgreSQL host for Kafka main storage bookkeeping")
-	rootCmd.PersistentFlags().Int("storage-main-kafka-postgres-port", 5432, "PostgreSQL port for Kafka main storage bookkeeping")
-	rootCmd.PersistentFlags().String("storage-main-kafka-postgres-username", "", "PostgreSQL username for Kafka main storage bookkeeping")
-	rootCmd.PersistentFlags().String("storage-main-kafka-postgres-password", "", "PostgreSQL password for Kafka main storage bookkeeping")
-	rootCmd.PersistentFlags().String("storage-main-kafka-postgres-database", "", "PostgreSQL database for Kafka main storage bookkeeping")
-	rootCmd.PersistentFlags().String("storage-main-kafka-postgres-sslMode", "require", "PostgreSQL SSL mode for Kafka main storage bookkeeping")
-	rootCmd.PersistentFlags().Int("storage-main-kafka-postgres-maxOpenConns", 25, "PostgreSQL max open connections for Kafka main storage bookkeeping")
-	rootCmd.PersistentFlags().Int("storage-main-kafka-postgres-maxIdleConns", 10, "PostgreSQL max idle connections for Kafka main storage bookkeeping")
+	rootCmd.PersistentFlags().String("storage-main-kafka-redis-host", "", "Redis host for Kafka main storage metadata")
+	rootCmd.PersistentFlags().Int("storage-main-kafka-redis-port", 6379, "Redis port for Kafka main storage metadata")
+	rootCmd.PersistentFlags().String("storage-main-kafka-redis-password", "", "Redis password for Kafka main storage metadata")
+	rootCmd.PersistentFlags().Int("storage-main-kafka-redis-db", 0, "Redis database number for Kafka main storage metadata")
 	rootCmd.PersistentFlags().String("api-host", "localhost:3000", "API host")
 	rootCmd.PersistentFlags().String("api-basicAuth-username", "", "API basic auth username")
 	rootCmd.PersistentFlags().String("api-basicAuth-password", "", "API basic auth password")
@@ -265,14 +261,10 @@ func init() {
 	viper.BindPFlag("storage.main.kafka.username", rootCmd.PersistentFlags().Lookup("storage-main-kafka-username"))
 	viper.BindPFlag("storage.main.kafka.password", rootCmd.PersistentFlags().Lookup("storage-main-kafka-password"))
 	viper.BindPFlag("storage.main.kafka.enable_tls", rootCmd.PersistentFlags().Lookup("storage-main-kafka-enable-tls"))
-	viper.BindPFlag("storage.main.kafka.postgres.host", rootCmd.PersistentFlags().Lookup("storage-main-kafka-postgres-host"))
-	viper.BindPFlag("storage.main.kafka.postgres.port", rootCmd.PersistentFlags().Lookup("storage-main-kafka-postgres-port"))
-	viper.BindPFlag("storage.main.kafka.postgres.username", rootCmd.PersistentFlags().Lookup("storage-main-kafka-postgres-username"))
-	viper.BindPFlag("storage.main.kafka.postgres.password", rootCmd.PersistentFlags().Lookup("storage-main-kafka-postgres-password"))
-	viper.BindPFlag("storage.main.kafka.postgres.database", rootCmd.PersistentFlags().Lookup("storage-main-kafka-postgres-database"))
-	viper.BindPFlag("storage.main.kafka.postgres.sslMode", rootCmd.PersistentFlags().Lookup("storage-main-kafka-postgres-sslMode"))
-	viper.BindPFlag("storage.main.kafka.postgres.maxOpenConns", rootCmd.PersistentFlags().Lookup("storage-main-kafka-postgres-maxOpenConns"))
-	viper.BindPFlag("storage.main.kafka.postgres.maxIdleConns", rootCmd.PersistentFlags().Lookup("storage-main-kafka-postgres-maxIdleConns"))
+	viper.BindPFlag("storage.main.kafka.redis.host", rootCmd.PersistentFlags().Lookup("storage-main-kafka-redis-host"))
+	viper.BindPFlag("storage.main.kafka.redis.port", rootCmd.PersistentFlags().Lookup("storage-main-kafka-redis-port"))
+	viper.BindPFlag("storage.main.kafka.redis.password", rootCmd.PersistentFlags().Lookup("storage-main-kafka-redis-password"))
+	viper.BindPFlag("storage.main.kafka.redis.db", rootCmd.PersistentFlags().Lookup("storage-main-kafka-redis-db"))
 	viper.BindPFlag("api.host", rootCmd.PersistentFlags().Lookup("api-host"))
 	viper.BindPFlag("api.basicAuth.username", rootCmd.PersistentFlags().Lookup("api-basicAuth-username"))
 	viper.BindPFlag("api.basicAuth.password", rootCmd.PersistentFlags().Lookup("api-basicAuth-password"))