diff --git a/tests/integration/sync_test.go b/tests/integration/sync_test.go
index e056956a2..a3b2780c0 100644
--- a/tests/integration/sync_test.go
+++ b/tests/integration/sync_test.go
@@ -814,7 +814,7 @@ var (
 					"database":            float64(0),
 					"host":                nil,
 					"keepalive_backlog":   nil,
-					"keepalive_pool_size": float64(30),
+					"keepalive_pool_size": float64(256),
 					"password":            nil,
 					"port":                nil,
 					"read_timeout":        nil,
@@ -880,7 +880,7 @@ var (
 					"database":            float64(0),
 					"host":                nil,
 					"keepalive_backlog":   nil,
-					"keepalive_pool_size": float64(30),
+					"keepalive_pool_size": float64(256),
 					"password":            nil,
 					"port":                nil,
 					"read_timeout":        nil,
@@ -929,7 +929,7 @@ var (
 					"database":            float64(0),
 					"host":                nil,
 					"keepalive_backlog":   nil,
-					"keepalive_pool_size": float64(30),
+					"keepalive_pool_size": float64(256),
 					"password":            nil,
 					"port":                nil,
 					"read_timeout":        nil,
@@ -975,7 +975,7 @@ var (
 					"database":            float64(0),
 					"host":                nil,
 					"keepalive_backlog":   nil,
-					"keepalive_pool_size": float64(30),
+					"keepalive_pool_size": float64(256),
 					"password":            nil,
 					"port":                nil,
 					"read_timeout":        nil,
@@ -3604,7 +3604,7 @@ func Test_Sync_SkipConsumers_34x(t *testing.T) {
 								"database":            float64(0),
 								"host":                nil,
 								"keepalive_backlog":   nil,
-								"keepalive_pool_size": float64(30),
+								"keepalive_pool_size": float64(256),
 								"password":            nil,
 								"port":                nil,
 								"read_timeout":        nil,
@@ -3653,7 +3653,7 @@ func Test_Sync_SkipConsumers_34x(t *testing.T) {
 								"database":            float64(0),
 								"host":                nil,
 								"keepalive_backlog":   nil,
-								"keepalive_pool_size": float64(30),
+								"keepalive_pool_size": float64(256),
 								"password":            nil,
 								"port":                nil,
 								"read_timeout":        nil,
@@ -3776,7 +3776,7 @@ func Test_Sync_SkipConsumers_Konnect(t *testing.T) {
 								"database":            float64(0),
 								"host":                nil,
 								"keepalive_backlog":   nil,
-								"keepalive_pool_size": float64(30),
+								"keepalive_pool_size": float64(256),
 								"password":            nil,
 								"port":                nil,
 								"read_timeout":        nil,
@@ -3825,7 +3825,7 @@ func Test_Sync_SkipConsumers_Konnect(t *testing.T) {
 								"database":            float64(0),
 								"host":                nil,
 								"keepalive_backlog":   nil,
-								"keepalive_pool_size": float64(30),
+								"keepalive_pool_size": float64(256),
 								"password":            nil,
 								"port":                nil,
 								"read_timeout":        nil,