search

jcustenborder / kafka-connect-redis

Kafka Connect connector for Redis
Apache License 2.0
60 stars 51 forks source link

Support Redis PubSub #6

Open jcustenborder opened 6 years ago

Bradleywboggs commented 3 years ago

@jcustenborder I may want to implement at least the ability to publish for a use-case at my company. Do you have some thoughts on how you want this accomplished? My initial thoughts: Config additions(something like): redis.action which could be one of 2 possibilities at this point: set or publish, defaulting to set redis.channel which would take your channel name

Update the put method do some logic based on the configs and execute the appropriate action.

It would probably ignore the key and just load the value into the channel. If people want to do any other transformations on the payload they can use/build an SMT.

Bradleywboggs commented 3 years ago

Looking a little closer at the put method, I see there's a little more going on there than I initially suspected. I think that the actions could be cache or pubsub. With the ultimate redis ops for cache being mset or delete, and the pubsub operation being publish ? I'm not feeling too certain on the naming of the things, so your thoughts are totally welcome here!