File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 6
6
"filters.Drop.type" : " io.streamthoughts.kafka.connect.filepulse.filter.DropFilter" ,
7
7
"filters.ParseCSVLine.extract.column.name" : " headers" ,
8
8
"filters.ParseCSVLine.trim.column" : " true" ,
9
- "filters.ParseCSVLine.seperator " : " ;" ,
10
- "filters.ParseCSVLine.type" : " io.streamthoughts.kafka.connect.filepulse.filter.DelimitedRowFilter " ,
9
+ "filters.ParseCSVLine.separator " : " ;" ,
10
+ "filters.ParseCSVLine.type" : " io.streamthoughts.kafka.connect.filepulse.filter.CSVFilter " ,
11
11
"fs.cleanup.policy.class" : " io.streamthoughts.kafka.connect.filepulse.fs.clean.LogCleanupPolicy" ,
12
12
"fs.cleanup.policy.triggered.on" :" COMMITTED" ,
13
13
"fs.listing.class" : " io.streamthoughts.kafka.connect.filepulse.fs.LocalFSDirectoryListing" ,
26
26
"tasks.file.status.storage.topic.partitions" : 10 ,
27
27
"tasks.file.status.storage.topic.replication.factor" : 1 ,
28
28
"tasks.max" : 1
29
- }
29
+ }
You can’t perform that action at this time.
0 commit comments