EXPIRE/DEL support

[IM-coding]

Hi! You have a great connector but lack EXPIRE support and/or DEL. Could we have one?

[jruaux]

Hi, yes that's something we can add to the sink connector. How do you foresee the usage for expire and del?

[IM-coding]

Thank you, for your reply!

Having a separate sink connector with redis.type=EXPIRE would be nice - users could set global TTL for all messages in the topic.
But adding this as a parameter to a Kafka message/header/key would be perfect and it would add more flexibility.
For example, a Kafka message with a header like expire_ttl: 1800 will set a key with a value and expire this key after 1800 s

As for DEL:
I've noticed in the documentation that there is an option to delete List, Set, Sorted Set if the value of the Kafka message is null.
I think the simplest solution would be adding this feature to String, Hash, JSON, and TimeSeries if it is possible.

[rsibweza]

I have loved this connection plugin for redis. unfortunately it lacks the most important factor for an in memory cache...The expiry ttl setting. I have a project going live soon unfortunately I won't be able to implement the kafka pipeline using this plugin because of this ttl issue