alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-4629 infinite retries

Browse Source
This commit is contained in:
ggaborg 2022-09-30 16:28:07 +03:00 committed by Jiri Pechanec
parent 11c588fb03
commit 001371e976
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java
View File

@ -196,7 +196,7 @@ public final class EmbeddedEngine implements DebeziumEngine<SourceRecord> {
.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).");

2
documentation/modules/ROOT/pages/development/engine.adoc
View File

@ -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`