diff --git a/client/internal/netflow/store/event_aggregation_test.go b/client/internal/netflow/store/event_aggregation_test.go
index 8064e0e4a..411177331 100644
--- a/client/internal/netflow/store/event_aggregation_test.go
+++ b/client/internal/netflow/store/event_aggregation_test.go
@@ -176,7 +176,7 @@ func generateEvents(srcIp, dstIp netip.Addr, dstPort uint16, eventTypes []types.
 		Timestamp: inEvents[0].Timestamp,
 		EventFields: types.EventFields{
 			FlowID:           flowId,
-			Type:             inEvents[0].Type,
+			Type:             types.TypeUnknown,
 			Protocol:         inEvents[0].Protocol,
 			RuleID:           []byte("rule-id-1"),
 			Direction:        inEvents[0].Direction,
diff --git a/client/internal/netflow/store/memory.go b/client/internal/netflow/store/memory.go
index fa2a0a3e1..b264bfd4a 100644
--- a/client/internal/netflow/store/memory.go
+++ b/client/internal/netflow/store/memory.go
@@ -134,7 +134,6 @@ func (am *AggregatingMemory) GetAggregatedEvents() []*types.Event {
 		if aggregatedEvent.Timestamp.Compare(v.Timestamp) > 0 {
 			aggregatedEvent.Timestamp = v.Timestamp
 			aggregatedEvent.ID = v.ID
-			aggregatedEvent.Type = v.Type
 		}
 	}