diff --git a/agents/libagents.go b/agents/libagents.go
index cfe39659b..a26fbf9cb 100644
--- a/agents/libagents.go
+++ b/agents/libagents.go
@@ -193,11 +193,12 @@ func processRequest(ctx *context.Context, reqProcessor *config.RequestProcessor,
 		Tenant: cgrEv.Tenant,
 		ID:     utils.GenUUID(),
 		Event: map[string]any{
-			utils.ReplyState:     replyState,
-			utils.StartTime:      startTime,
-			utils.EndTime:        endTime,
-			utils.ProcessingTime: endTime.Sub(startTime),
-			utils.Source:         agentName,
+			utils.ReplyState:         replyState,
+			utils.StartTime:          startTime,
+			utils.EndTime:            endTime,
+			utils.ProcessingTime:     endTime.Sub(startTime),
+			utils.Source:             agentName,
+			utils.RequestProcessorID: reqProcessor.ID,
 		},
 		APIOpts: map[string]any{
 			utils.MetaEventType: utils.ProcessTime,
diff --git a/agents/radagent.go b/agents/radagent.go
index 4ecf72812..f6780f0fc 100644
--- a/agents/radagent.go
+++ b/agents/radagent.go
@@ -471,11 +471,12 @@ func (ra *RadiusAgent) processRequest(req *radigo.Packet, reqProcessor *config.R
 		Tenant: cgrEv.Tenant,
 		ID:     utils.GenUUID(),
 		Event: map[string]any{
-			utils.ReplyState:     replyState,
-			utils.StartTime:      startTime,
-			utils.EndTime:        endTime,
-			utils.ProcessingTime: endTime.Sub(startTime),
-			utils.Source:         utils.RadiusAgent,
+			utils.ReplyState:         replyState,
+			utils.StartTime:          startTime,
+			utils.EndTime:            endTime,
+			utils.ProcessingTime:     endTime.Sub(startTime),
+			utils.Source:             utils.RadiusAgent,
+			utils.RequestProcessorID: reqProcessor.ID,
 		},
 		APIOpts: map[string]any{
 			utils.MetaEventType: utils.ProcessTime,
diff --git a/agents/sipagent.go b/agents/sipagent.go
index 9c4515fc2..4eaa6ae23 100644
--- a/agents/sipagent.go
+++ b/agents/sipagent.go
@@ -469,11 +469,12 @@ func (sa *SIPAgent) processRequest(reqProcessor *config.RequestProcessor,
 		Tenant: cgrEv.Tenant,
 		ID:     utils.GenUUID(),
 		Event: map[string]any{
-			utils.ReplyState:     replyState,
-			utils.StartTime:      startTime,
-			utils.EndTime:        endTime,
-			utils.ProcessingTime: endTime.Sub(startTime),
-			utils.Source:         utils.SIPAgent,
+			utils.ReplyState:         replyState,
+			utils.StartTime:          startTime,
+			utils.EndTime:            endTime,
+			utils.ProcessingTime:     endTime.Sub(startTime),
+			utils.Source:             utils.SIPAgent,
+			utils.RequestProcessorID: reqProcessor.ID,
 		},
 		APIOpts: map[string]any{
 			utils.MetaEventType: utils.ProcessTime,
diff --git a/ers/ers.go b/ers/ers.go
index 841028ea7..0ed42f6d7 100644
--- a/ers/ers.go
+++ b/ers/ers.go
@@ -216,6 +216,7 @@ func (erS *ERService) processEvent(cgrEv *utils.CGREvent,
 				utils.EndTime:        endTime,
 				utils.ProcessingTime: endTime.Sub(startTime),
 				utils.Source:         utils.ERs,
+				utils.EventReaderID:  rdrCfg.ID,
 			},
 			APIOpts: map[string]any{
 				utils.MetaEventType: utils.ProcessTime,
diff --git a/utils/consts.go b/utils/consts.go
index b2f5d68c0..db96e45fe 100644
--- a/utils/consts.go
+++ b/utils/consts.go
@@ -520,37 +520,39 @@ const (
 	User          = "User"
 	Subscribers   = "Subscribers"
 	//Destinations             = "Destinations"
-	MetaSubscribers   = "*subscribers"
-	MetaDataDB        = "*datadb"
-	MetaStorDB        = "*stordb"
-	MetaWeight        = "*weight"
-	MetaLC            = "*lc"
-	MetaHC            = "*hc"
-	MetaQOS           = "*qos"
-	MetaReas          = "*reas"
-	MetaReds          = "*reds"
-	Weight            = "Weight"
-	Limit             = "Limit"
-	UsageTTL          = "UsageTTL"
-	Usages            = "Usages"
-	TTLIdx            = "TTLIdx"
-	AllocationMessage = "AllocationMessage"
-	AddressPool       = "AddressPool"
-	Pools             = "Pools"
-	Allocations       = "Allocations"
-	TTLIndex          = "TTLIndex"
-	Allocation        = "Allocation"
-	Range             = "Range"
-	Stored            = "Stored"
-	RatingSubject     = "RatingSubject"
-	Categories        = "Categories"
-	Blocker           = "Blocker"
-	Blockers          = "Blockers"
-	Params            = "Params"
-	StartTime         = "StartTime"
-	EndTime           = "EndTime"
-	ProcessingTime    = "ProcessingTime"
-	ReplyState        = "ReplyState"
+	MetaSubscribers    = "*subscribers"
+	MetaDataDB         = "*datadb"
+	MetaStorDB         = "*stordb"
+	MetaWeight         = "*weight"
+	MetaLC             = "*lc"
+	MetaHC             = "*hc"
+	MetaQOS            = "*qos"
+	MetaReas           = "*reas"
+	MetaReds           = "*reds"
+	Weight             = "Weight"
+	Limit              = "Limit"
+	UsageTTL           = "UsageTTL"
+	Usages             = "Usages"
+	TTLIdx             = "TTLIdx"
+	AllocationMessage  = "AllocationMessage"
+	AddressPool        = "AddressPool"
+	Pools              = "Pools"
+	Allocations        = "Allocations"
+	TTLIndex           = "TTLIndex"
+	Allocation         = "Allocation"
+	Range              = "Range"
+	Stored             = "Stored"
+	RatingSubject      = "RatingSubject"
+	Categories         = "Categories"
+	Blocker            = "Blocker"
+	Blockers           = "Blockers"
+	Params             = "Params"
+	StartTime          = "StartTime"
+	EndTime            = "EndTime"
+	ProcessingTime     = "ProcessingTime"
+	ReplyState         = "ReplyState"
+	RequestProcessorID = "RequestProcessorID"
+	EventReaderID      = "EventReaderID"
 
 	// ReplyState error constants
 	ErrReplyStateAuthorize = "ERR_AUTHORIZE"