diff --git a/app/proxyman/inbound/worker.go b/app/proxyman/inbound/worker.go
index 296eb0f85..044678089 100644
--- a/app/proxyman/inbound/worker.go
+++ b/app/proxyman/inbound/worker.go
@@ -244,7 +244,7 @@ func (w *udpWorker) removeConn(id connID) {
 func (w *udpWorker) Start() error {
 	w.activeConn = make(map[connID]*udpConn, 16)
 	w.done = signal.NewDone()
-	h, err := udp.ListenUDP(w.address, w.port, w.callback, udp.HubReceiveOriginalDestination(w.recvOrigDest))
+	h, err := udp.ListenUDP(w.address, w.port, w.callback, udp.HubReceiveOriginalDestination(w.recvOrigDest), udp.HubCapacity(256))
 	if err != nil {
 		return err
 	}
diff --git a/transport/internet/kcp/listener.go b/transport/internet/kcp/listener.go
index f35f57eff..12786cc02 100644
--- a/transport/internet/kcp/listener.go
+++ b/transport/internet/kcp/listener.go
@@ -61,7 +61,7 @@ func NewListener(ctx context.Context, address net.Address, port net.Port, addCon
 		l.tlsConfig = config.GetTLSConfig()
 	}
 
-	hub, err := udp.ListenUDP(address, port, l.OnReceive, udp.HubCapacity(64))
+	hub, err := udp.ListenUDP(address, port, l.OnReceive, udp.HubCapacity(1024))
 	if err != nil {
 		return nil, err
 	}
diff --git a/transport/internet/udp/hub.go b/transport/internet/udp/hub.go
index 52b2b510f..d92df47d9 100644
--- a/transport/internet/udp/hub.go
+++ b/transport/internet/udp/hub.go
@@ -47,7 +47,7 @@ func ListenUDP(address net.Address, port net.Port, callback PayloadHandler, opti
 	newError("listening UDP on ", address, ":", port).WriteToLog()
 	hub := &Hub{
 		conn:         udpConn,
-		capacity:     16,
+		capacity:     256,
 		callback:     callback,
 		recvOrigDest: false,
 	}