From 834eba6e06b56c911da98c06fdcd7899ce12c1f4 Mon Sep 17 00:00:00 2001 From: programmer10110 Date: Mon, 19 Oct 2020 15:01:17 +0300 Subject: [PATCH] fix dc4bc_d --- cmd/dc4bc_d/main.go | 21 ++++++++++----------- 1 file changed, 10 insertions(+), 11 deletions(-) diff --git a/cmd/dc4bc_d/main.go b/cmd/dc4bc_d/main.go index a35e022..1b3baf3 100644 --- a/cmd/dc4bc_d/main.go +++ b/cmd/dc4bc_d/main.go @@ -94,15 +94,15 @@ func startClientCommand() *cobra.Command { log.Fatalf("failed to read configuration: %v", err) } - //storageDBDSN, err := cmd.Flags().GetString(flagStorageDBDSN) - //if err != nil { - // log.Fatalf("failed to read configuration: %v", err) - //} - // - //storageTopic, err := cmd.Flags().GetString(flagStorageTopic) - //if err != nil { - // log.Fatalf("failed to read configuration: %v", err) - //} + storageDBDSN, err := cmd.Flags().GetString(flagStorageDBDSN) + if err != nil { + log.Fatalf("failed to read configuration: %v", err) + } + + storageTopic, err := cmd.Flags().GetString(flagStorageTopic) + if err != nil { + log.Fatalf("failed to read configuration: %v", err) + } keyStoreDBDSN, err := cmd.Flags().GetString(flagStoreDBDSN) if err != nil { @@ -117,8 +117,7 @@ func startClientCommand() *cobra.Command { log.Fatalf("Failed to init state client: %v", err) } - //stg, err := storage.NewKafkaStorage(ctx, storageDBDSN, storageTopic) - stg, err := storage.NewFileStorage("/tmp/dc4bc_storage") + stg, err := storage.NewKafkaStorage(ctx, storageDBDSN, storageTopic) if err != nil { log.Fatalf("Failed to init storage client: %v", err) }