diff --git a/client/internal/netflow/store/memory.go b/client/internal/netflow/store/memory.go
index b264bfd4a..6f689b695 100644
--- a/client/internal/netflow/store/memory.go
+++ b/client/internal/netflow/store/memory.go
@@ -134,6 +134,7 @@ func (am *AggregatingMemory) GetAggregatedEvents() []*types.Event {
 		if aggregatedEvent.Timestamp.Compare(v.Timestamp) > 0 {
 			aggregatedEvent.Timestamp = v.Timestamp
 			aggregatedEvent.ID = v.ID
+			aggregatedEvent.SourcePort = v.SourcePort
 		}
 	}