Andrew Stevenson
Andrew Stevenson
@isaranchuk Theres an example [here](https://github.com/lensesio/stream-reactor/blob/master/kafka-connect-jms/src/main/scala/com/datamountaineer/streamreactor/connect/jms/config/JMSSettings.scala#L121). You would need to introduce a delete trait that has a function that accepts the SinkRecord inside which you do want ever you want and...
@isaranchuk There's a writer implementing the behaviour already for each Redis structure we support. I'm not a Redis expert but are you saying that each structure has one or more...
@isaranchuk if you look at the writer classes, one for each redis structure it has access to jedis. If you write a delete handler you just need return the key...
@isaranchuk fair enough.
@isaranchuk You would just have a trait that has a function. I think you want it per writer as one connector can handle multiple topics (KCQL stmts) so you might...
@isaranchuk We don't have a Redis source. My point is that there's no reason to enforce a connector wide handler when we can handle it at the writer level and...
@xuzikun2003 no its not currently supported if you want each topic to go to a separate influxdb. PRs welcome! But how would you handle credentials per db in KCQL securely.
@alfamegaxq you are using the wrong converters. https://docs.lenses.io/connectors/sink/influx.html#schema-string-and-a-json-payload
@pathiec92 The tests for mongo fail. Can you have a look?
@amq we'll take a look. If you would like to sponsor the work it can always get it done quicker, drop me a direct mail if you want to know...