Added new retry codes (#237)

* Added new retry codes
ClickHouse · Nov 7, 2023 · 8a2ef2a · 8a2ef2a
1 parent f0c8ed5
commit 8a2ef2a
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,7 @@
-## 1.0.3 2023-11-XX
+## 1.0.3 2023-11-07
 * Added support for proxy configurations
+* Additional test cases
+* Additional error codes added to retry list (242, 319, 999)
 
 ## 1.0.2 2023-11-02
 * Updated dependencies

diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-v1.0.2
+v1.0.3
diff --git a/src/main/java/com/clickhouse/kafka/connect/util/Utils.java b/src/main/java/com/clickhouse/kafka/connect/util/Utils.java
@@ -65,9 +65,12 @@ public static void handleException(Exception e, boolean errorsTolerance) {
                 case 203: // NO_FREE_CONNECTION
                 case 209: // SOCKET_TIMEOUT
                 case 210: // NETWORK_ERROR
+                case 242: // TABLE_IS_READ_ONLY
                 case 252: // TOO_MANY_PARTS
                 case 285: // TOO_FEW_LIVE_REPLICAS
+                case 319: // UNKNOWN_STATUS_OF_INSERT
                 case 425: // SYSTEM_ERROR
+                case 999: // KEEPER_EXCEPTION
                 case 1002: // UNKNOWN_EXCEPTION
                     throw new RetriableException(e);
                 default: