fix(firehose): reset offset not updated (#63)

goto · Sep 7, 2023 · 9fbfe36 · 9fbfe36
1 parent e62530f
commit 9fbfe36
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/server/v1/firehose/mappings.go b/internal/server/v1/firehose/mappings.go
@@ -74,6 +74,7 @@ func makeConfigStruct(cfg *models.FirehoseConfig) (*structpb.Value, error) {
 		},
 		DeploymentID: cfg.DeploymentID,
 		EnvVariables: cfg.EnvVars,
+		ResetOffset:  cfg.ResetOffset,
 	})
 }