"",脚本如下:{
"content": [
{
"reader": {
"parameter": {
"path": "/tmp/1062002199883677696.csv",
"column": [
{
"name": "code",
"type": "varchar",
"index": 0
},
{
"name": "equipment_no",
"type": "varchar",
"index": 1
},
{
"name": "time",
"type": "varchar",
"index": 2
}
],
"defaultFS": "hdfs://192.168.36.201:9000",
"fieldDelimiter": ",",
"fileType": "text"
},
"name": "hdfsreader"
},
"writer": {
"parameter": {
"timezone": "UTC",
"topic": "63bba829dc4881000116a4cc",
"producerSettings": {
"bootstrap.servers": "192.168.36.201:9091,192.168.36.201:9092"
},
"tableFields": [
"code",
"equipment_no",
"time"
],
"partitionAssignColumns": [
"code"
]
},
"name": "kafkawriter"
}
}
],
"setting": {
"restore": {
"isRestore": false
},
"log": {
"path": "",
"level": "debug",
"pattern": "",
"isLogger": false
},
"errorLimit": {
"record": 100
},
"speed": {
"channel": 1
}
}
}