This is made a lot easier now since pubsub support is now handled at the codec layer, instead of within RedisSinkSingle as it was originally implemented.
Possibly it already works and we just need to add integration test, but I suspect something will be broken.
This is made a lot easier now since pubsub support is now handled at the codec layer, instead of within RedisSinkSingle as it was originally implemented.
Possibly it already works and we just need to add integration test, but I suspect something will be broken.