fix log

Author: hantmac

src/main/java/com/databend/kafka/connect/sink/DatabendWriter.java

@@ -52,7 +52,9 @@ void write(final Collection<SinkRecord> records)
             final Map<TableIdentity, BufferedRecords> bufferByTable = new HashMap<>();
             for (SinkRecord record : records) {
                 log.info("DatabendWriter Writing record keySchema is: {}", record.keySchema());
-                log.info("DatabendWriter Writing record valueSchema is: {}", record.valueSchema().fields());
+                if (record.valueSchema() != null) {
+                    log.info("DatabendWriter Writing record valueSchema is: {}", record.valueSchema().fields());
+                }
                 log.info("DatabendWriter Writing record key is: {}", record.key());
                 log.info("DatabendWriter Writing record value is: {}", record.value());
                 log.info("DatabendWriter Writing record topic is: {}", record.topic());

target/components/packages/databendCloud-databend-kafka-connect-0.0.1-SNAPSHOT/databendCloud-databend-kafka-connect-0.0.1-SNAPSHOT/manifest.json

@@ -31,5 +31,5 @@
     "url" : "https://www.apache.org/licenses/LICENSE-2.0"
   } ],
   "component_types" : [ "sink" ],
-  "release_date" : "2024-07-14"
+  "release_date" : "2024-07-15"
 }

target/manifest.json

@@ -31,5 +31,5 @@
     "url" : "https://www.apache.org/licenses/LICENSE-2.0"
   } ],
   "component_types" : [ "sink" ],
-  "release_date" : "2024-07-14"
+  "release_date" : "2024-07-15"
 }