Changing back for now

Changing this back for now because the version we use doesn't support "auto"
ClickHouse · Jul 16, 2023 · dd8f2d9 · dd8f2d9
1 parent 91a2796
commit dd8f2d9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/clickhouse/kafka/connect/sink/db/ClickHouseWriter.java b/src/main/java/com/clickhouse/kafka/connect/sink/db/ClickHouseWriter.java
@@ -379,7 +379,7 @@ public void doInsertRawBinary(List<Record> records) throws IOException, Executio
                     .table(table.getName())
                     .format(ClickHouseFormat.RowBinary)
                     // this is needed to get meaningful response summary
-                    .set("insert_quorum", "auto")
+                    .set("insert_quorum", 2)
                     .set("send_progress_in_http_headers", 1);
 
             ClickHouseConfig config = request.getConfig();
@@ -451,7 +451,7 @@ public void doInsertJson(List<Record> records) throws IOException, ExecutionExce
                     .table(table.getName())
                     .format(ClickHouseFormat.JSONEachRow)
                     // this is needed to get meaningful response summary
-                    .set("insert_quorum", "auto")
+                    .set("insert_quorum", 2)
                     .set("input_format_skip_unknown_fields", 1)
                     .set("send_progress_in_http_headers", 1);