Merge pull request #736 from Altinity/734-json-validate-error-when-parsing-status

Convert localDateTime to String in show_replica_status API call

Author: subkanthi

sink-connector-lightweight/src/main/java/com/altinity/clickhouse/debezium/embedded/cdc/DebeziumChangeEventCapture.java

@@ -39,6 +39,7 @@
 import java.sql.ResultSet;
 import java.sql.ResultSetMetaData;
 import java.sql.SQLException;
+import java.time.LocalDateTime;
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -442,7 +443,11 @@ public String getDebeziumStorageStatus(ClickHouseSinkConnectorConfig config, Pro
                 JSONObject row = new JSONObject();
                 colNames.forEach(cn -> {
                     try {
-                        row.put(cn, resultSet.getObject(cn));
+                        Object v = resultSet.getObject(cn);
+                        if (v != null && v instanceof LocalDateTime) {
+                            v = ((LocalDateTime) v).toString();
+                        }
+                        row.put(cn, v);
                     } catch (SQLException e) {
                         e.printStackTrace();
                     }
@@ -577,6 +582,7 @@ public void setupDebeziumEventCapture(Properties props, DebeziumRecordParserServ
         // Create the engine with this configuration ...
         try {
             DebeziumEngine.Builder<ChangeEvent<SourceRecord, SourceRecord>> changeEventBuilder = DebeziumEngine.create(Connect.class);
+
             changeEventBuilder.using(props);
             changeEventBuilder.notifying(new DebeziumEngine.ChangeConsumer<ChangeEvent<SourceRecord, SourceRecord>>() {
                 @Override