Merge pull request #36 from taosdata/fix/2.x/TD-24553

fix: add data type
taosdata · Jun 6, 2023 · 0153f38 · 0153f38
2 parents 8c71fe0 + cbec902
commit 0153f38
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/com/taosdata/kafka/connect/source/LineMapper.java b/src/main/java/com/taosdata/kafka/connect/source/LineMapper.java
@@ -87,6 +87,7 @@ public PendingRecord doExtractRecord(ResultSet resultSet, Map<String, String> pa
                         columnString.append(column).append("=").append(resultSet.getDouble(column)).append("f64,");
                         break;
                     case "BINARY":
+                    case "VARCHAR":
                         columnString.append(column).append("=\"").append(resultSet.getString(column)).append("\",");
                         break;
                     case "BOOL":