diff --git a/pkg/internal/grpc/stream.go b/pkg/internal/grpc/stream.go
index 8b82427..059f0ac 100644
--- a/pkg/internal/grpc/stream.go
+++ b/pkg/internal/grpc/stream.go
@@ -87,9 +87,6 @@ func (v *App) PushStream(_ context.Context, request *proto.PushStreamRequest) (*
 		}
 
 		err := jsoniter.Unmarshal(in.RawPayload(), &data)
-		if request.ClientId != nil {
-			data.ClientID = *request.ClientId
-		}
 		if err == nil {
 			err = exts.ValidateStruct(data)
 		}