diff --git a/outbox-kafka-spring-reactive/src/test/java/one/tomorrow/transactionaloutbox/reactive/AbstractIntegrationTest.java b/outbox-kafka-spring-reactive/src/test/java/one/tomorrow/transactionaloutbox/reactive/AbstractIntegrationTest.java index 0b0e14ac..c6f59b69 100644 --- a/outbox-kafka-spring-reactive/src/test/java/one/tomorrow/transactionaloutbox/reactive/AbstractIntegrationTest.java +++ b/outbox-kafka-spring-reactive/src/test/java/one/tomorrow/transactionaloutbox/reactive/AbstractIntegrationTest.java @@ -54,6 +54,9 @@ public static void setR2DBCProperties(DynamicPropertyRegistry registry) { registry.add("spring.r2dbc.pool.enabled", () -> "true"); registry.add("spring.r2dbc.pool.initial-size", () -> "5"); registry.add("spring.r2dbc.pool.max-size", () -> "10"); + // Prevent "Could not open R2DBC Connection", caused by "Connection unexpectedly closed" + registry.add("spring.r2dbc.pool.aquire-retry", () -> "5"); + registry.add("spring.r2dbc.pool.validation-query", () -> "select 1"); } }