From 001371e9760e3eef3d4440115132ab7a455d032c Mon Sep 17 00:00:00 2001 From: ggaborg Date: Fri, 30 Sep 2022 16:28:07 +0300 Subject: [PATCH] DBZ-4629 infinite retries --- .../src/main/java/io/debezium/embedded/EmbeddedEngine.java | 2 +- documentation/modules/ROOT/pages/development/engine.adoc | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 02858a7b0..b7902c3e7 100644 --- a/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java +++ b/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java @@ -196,7 +196,7 @@ public final class EmbeddedEngine implements DebeziumEngine { .withType(Type.INT) .withWidth(Width.SHORT) .withImportance(Importance.MEDIUM) - .withDefault(0) + .withDefault(-1) .withValidation(Field::isInteger) .withDescription("The maximum number of retries on connection errors before failing (-1 = no limit, 0 = disabled, > 0 = num of retries)."); diff --git a/documentation/modules/ROOT/pages/development/engine.adoc b/documentation/modules/ROOT/pages/development/engine.adoc index 615c099a8..61a8e3bc7 100644 --- a/documentation/modules/ROOT/pages/development/engine.adoc +++ b/documentation/modules/ROOT/pages/development/engine.adoc @@ -433,7 +433,7 @@ The default is a periodic commity policy based upon time intervals. |Maximum number of milliseconds to wait for records to flush and partition offset data to be committed to offset storage before cancelling the process and restoring the offset data to be committed in a future attempt. The default is 5 seconds. |`errors.max.retries` -|`0` +|`-1` |The maximum number of retries on connection errors before failing (-1 = no limit, 0 = disabled, > 0 = num of retries). |`errors.retry.delay.initial.ms`