diff --git a/cmd/dc4bc_d/main.go b/cmd/dc4bc_d/main.go
index 4206bc2..d7bee62 100644
--- a/cmd/dc4bc_d/main.go
+++ b/cmd/dc4bc_d/main.go
@@ -96,7 +96,7 @@ func startClientCommand() *cobra.Command {
 				log.Fatalf("Failed to init state client: %v", err)
 			}
 
-			stg, err := storage.NewFileStorage(storageDBDSN)
+			stg, err := storage.NewKafkaStorage(context.Background(), storageDBDSN)
 			if err != nil {
 				log.Fatalf("Failed to init storage client: %v", err)
 			}
diff --git a/dc4bc_airgapped b/dc4bc_airgapped
index 7ffe7c1..bb80c70 100755
Binary files a/dc4bc_airgapped and b/dc4bc_airgapped differ
diff --git a/dc4bc_d b/dc4bc_d
index 5bd63eb..6999cdd 100755
Binary files a/dc4bc_d and b/dc4bc_d differ