Andrew Stevenson
Andrew Stevenson
@abratnap KCQL supports an UPDATE mode, you could implement this in the connector. Are you up to contributing this feature?
this needs a fix in `avro-sql` coming in from Landoops repos. We can have a look but it'll be a few days before we get to it.
We need to update the underlying avro-sql and json-sql libraries. I think it will be a month or so be for we have time, We do accept Pull requets, maybe...
@sjmittal this would require an update to KCQL since it doesn't handle the functions yet in the parser.
@sjmittal The Cassandra source fires a CQL query. Have you tried putting the TOUNIXTIMESTAMP function in the select statement?
@sjmittal are you up for contributing this back? Probably with a configuration option to control the behaviour?
@isaranchuk I haven't looked at confluents sink, I assume it there is a one to one mapping between the key in the Kafka message and Redis, this should be easy...
@isaranchuk @hsomyk i have it in a branch. I just need to write some tests. I'll push tomorrow
@isaranchuk I've pushed to feat/redis-delete but I don't have unit tests yet. If you want to take over this ticket feel free, we should also bump the Jedis version so...
@isaranchuk Its possible to create interface. The default would be the one to one mapping I put in but the user can supply a custom delete class for it. We...