diff --git a/lightning/lnd.go b/lightning/lnd.go
index a9dfb97..2e5b7de 100644
--- a/lightning/lnd.go
+++ b/lightning/lnd.go
@@ -324,6 +324,11 @@ func (l LndClient) SubscribeChannelUpdates(ctx context.Context) (<-chan Channels
 			case h := <-htlcs:
 				channels := make(Channels, 0)
 
+				// attempt to filter on forward events
+				if h.GetForwardEvent() == nil {
+					continue
+				}
+
 				if h.GetIncomingChannelId() != 0 {
 					c, err := l.GetChannel(ctx, ChannelID(h.GetIncomingChannelId()))
 					if err != nil {