diff --git a/pkg/internal/grpc/stream.go b/pkg/internal/grpc/stream.go
index 059f0ac..9c7d518 100644
--- a/pkg/internal/grpc/stream.go
+++ b/pkg/internal/grpc/stream.go
@@ -113,7 +113,7 @@ func (v *App) PushStream(_ context.Context, request *proto.PushStreamRequest) (*
 
 		// Forward ack request
 		sc.PushStream(context.Background(), &proto.PushStreamRequest{
-			ClientId: request.ClientId,
+			ClientId: &data.ClientID,
 			Body: nex.WebSocketPackage{
 				Action:  "kex.ack",
 				Payload: data,