diff --git a/services/eventhistory/pkg/command/server.go b/services/eventhistory/pkg/command/server.go
index f58dbe8c89..43b90a6722 100644
--- a/services/eventhistory/pkg/command/server.go
+++ b/services/eventhistory/pkg/command/server.go
@@ -59,7 +59,7 @@ func Server(cfg *config.Config) *cobra.Command {
 
 			gr := runner.NewGroup()
 
-			var consumer events.Consumer
+			var consumer events.Stream
 			if !cfg.Events.Disabled {
 				connName := generators.GenerateConnectionName(cfg.Service.Name, generators.NTypeBus)
 				consumer, err = stream.NatsFromConfig(connName, false, stream.NatsConfig{