diff --git a/pkg/streamer/streamer.go b/pkg/streamer/streamer.go
index 145820e..7123b15 100644
--- a/pkg/streamer/streamer.go
+++ b/pkg/streamer/streamer.go
@@ -139,6 +139,8 @@ func NewReadResImpl(before, after []byte, matchedGroups map[string][]byte, match
 // TCPDialCtx net.Dial version with context arg
 func TCPDialCtx(ctx context.Context, network, addr string) (net.Conn, error) {
 	d := net.Dialer{}
+	ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
+	defer cancel()
 	conn, err := d.DialContext(ctx, network, addr)
 	if err != nil {
 		return nil, err