From 5b14097a94c154c997024f06debbf7e8b7d52e32 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Michal=20August=C3=BDn?= <michal.augustyn@gendigital.com>
Date: Mon, 13 May 2024 22:39:11 +0200
Subject: [PATCH] DBZ-7870 default value of -1 for connection error retries
 interpreted as no limit

---
 COPYRIGHT.txt                                                   | 1 +
 .../src/main/java/io/debezium/embedded/EmbeddedEngine.java      | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/COPYRIGHT.txt b/COPYRIGHT.txt
index 7247b38fe..64bb81bd7 100644
--- a/COPYRIGHT.txt
+++ b/COPYRIGHT.txt
@@ -350,6 +350,7 @@ Meng Qiu
 Melissa Winstanley
 Michael Cizmar
 Michael Wang
+Michal Augustyn
 Mickael Maison
 Mickaël Isaert
 Mike Graham
diff --git a/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java b/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java
index 4e80d0687..1177019bd 100644
--- a/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java
+++ b/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java
@@ -672,7 +672,7 @@ private Throwable handleRetries(final RetriableException e, final List<Map<Strin
                 startedSuccessfully = true;
             }
             catch (Exception ex) {
-                if (totalRetries >= maxRetries) {
+                if (maxRetries != EmbeddedEngineConfig.DEFAULT_ERROR_MAX_RETRIES && totalRetries >= maxRetries) {
                     LOGGER.error("Can't start the connector, max retries to connect exceeded; stopping connector...", ex);
                     return ex;
                 }