diff --git a/collectors/forwarder/serv/service.go b/collectors/forwarder/serv/service.go
index 695d74cbc..df78b8074 100644
--- a/collectors/forwarder/serv/service.go
+++ b/collectors/forwarder/serv/service.go
@@ -88,7 +88,7 @@ func (p *program) run() {
 
 	ctx = metadata.AppendToOutgoingContext(ctx, "key", cnf.CollectorKey)
 	ctx = metadata.AppendToOutgoingContext(ctx, "id", strconv.Itoa(int(cnf.CollectorID)))
-	ctx = metadata.AppendToOutgoingContext(ctx, "type", "agent")
+	ctx = metadata.AppendToOutgoingContext(ctx, "type", "collector")
 
 	p.goSafe("StartPing", func() {
 		upstream.StartPing(cnf, ctx)