DBZ-8193 Reset retries on success

debezium · Oct 7, 2024 · acda84c · acda84c
1 parent 76be795
commit acda84c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/debezium-server-kinesis/src/main/java/io/debezium/server/kinesis/KinesisChangeConsumer.java b/debezium-server-kinesis/src/main/java/io/debezium/server/kinesis/KinesisChangeConsumer.java
@@ -196,6 +196,7 @@ public void handleBatch(List<ChangeEvent<Object, Object>> records, RecordCommitt
                         }
                         else {
                             notSuccesful = false;
+                            attempts = 0;
                         }
 
                     }