我有以下阅读csv的请求
“connector.class”:“com.github.jcustenborder.Kafka.connect.spooldir.SpoolDirCsvSourceConnector”,“tasks.max”:1,“input.path”:“C:/Risvan/kafka-connect/connect/local-kafka/unprocessed”,“input.file.pattern”:“sample4.csv”,“error.path”:“C:/Risvan/kafka-connect/connect/local-kafka/error”,“finished.path”:“C:/Risvan/kafka-connect/connect/local-kafka/processed”,“topic”:“topic21”“csv.first.row.as.header”:true,“schema.generation.enabled:true,“transforms”:“castTypes”,“transforms.castTypes.type”:“org.apache.Kafka.connect.transforms.Cast$Value”,“transforms.castTypes.spec”:“phone:int64”
如何指定字段在这里属于日期类型。如果我用
"transforms.castTypes.spec":"phone:int64,date:date"
字符串
它显示
Invalid value java.lang.IllegalArgumentException: No enum constant
org.apache.kafka.connect.data.Schema.Type.DATE for configuration Invalid type found
in casting spec: date
型
日期格式为“05-07-2023 15:30:00”
是否有任何方法可以指定字段的日期类型?
1条答案
按热度按时间w6mmgewl1#
Kafka Connect没有Date类型。
把它当作一根弦。如果必须解析为其他格式,请使用TimestampConverter转换