-
Couldn't load subscription status.
- Fork 71
Description
Hi, I wan to add key to record but its not working any help is highly appreciated. connector version 2.16.0
Error: class io.streamthoughts.kafka.connect.filepulse.expression.SubstitutionExpression cannot be cast to class io.streamthoughts.kafka.connect.filepulse.expression.PropertyExpression (io.streamthoughts.kafka.connect.filepulse.expression.SubstitutionExpression and io.streamthoughts.kafka.connect.filepulse.expression.PropertyExpression are in unnamed module of loader org.apache.kafka.connect.runtime.isolation.PluginClassLoader @13b13b5d) (io.streamthoughts.kafka.connect.filepulse.filter.DefaultRecordFilterPipeline:183)
its a csv file using DelimitedRowFilter. file parsing is working fine
config
"filters":"ParseDelimited,SetKey", "filters.ParseDelimited.type": "io.streamthoughts.kafka.connect.filepulse.filter.DelimitedRowFilter", "filters.ParseDelimited.separator": "\\|", "filters.ParseDelimited.trim": "true", "filters.ParseDelimited.trim.column": "true", "filters.SetKey.type": "io.streamthoughts.kafka.connect.filepulse.filter.AppendFilter", "filters.SetKey.field": "filename", "filters.SetKey.value": "{{ $metadata.name }}",