Kafka 如何在SpoolDirCsvSourceConnector的请求体中指定日期类型

yftpprvb  于 2023-08-02  发布在  Apache
关注(0)|答案(1)|浏览(99)

我有以下阅读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”
是否有任何方法可以指定字段的日期类型?

w6mmgewl

w6mmgewl1#

Kafka Connect没有Date类型。
把它当作一根弦。如果必须解析为其他格式,请使用TimestampConverter转换

相关问题