diff --git a/broker/memory.go b/broker/memory.go
index 83c69c16..c94d2e5b 100644
--- a/broker/memory.go
+++ b/broker/memory.go
@@ -239,9 +239,7 @@ func (b *Memory) HandleBroadcast(msg *common.StreamMessage) {
 	msg.Epoch = b.GetEpoch()
 	msg.Offset = offset
 
-	if b.tracker.Has(msg.Stream) {
-		b.broadcaster.Broadcast(msg)
-	}
+	b.broadcaster.Broadcast(msg)
 }
 
 func (b *Memory) HandleCommand(msg *common.RemoteCommandMessage) {
diff --git a/broker/nats.go b/broker/nats.go
index 0d5db89d..026fc6f7 100644
--- a/broker/nats.go
+++ b/broker/nats.go
@@ -328,9 +328,7 @@ func (n *NATS) HandleBroadcast(msg *common.StreamMessage) {
 	msg.Epoch = n.Epoch()
 	msg.Offset = offset
 
-	if n.tracker.Has(msg.Stream) {
-		n.broadcaster.Broadcast(msg)
-	}
+	n.broadcaster.Broadcast(msg)
 }
 
 func (n *NATS) HandleCommand(msg *common.RemoteCommandMessage) {