Egoist

`Instead of subscribing for a channel to a random node in a cluster` How are you subscribing to a random node ? are you using ? - `redisClient.connectPubSub().sync().subscribe(channelName)` The default...

yeah, I am using the same StatefulRedisClusterPubSubConnection.sync().subscribe() call. But for multiple calls of this method for different channelNames, isn't the subscriptions happening on a single redis node - the one...

Thanks for your response. ``` Right now I am using StatefulRedisClusterConnection.getPartitions().getPartitionBySlot(SlotHash.getSlot(channel)).getNodeId() to get the respective nodeId. From nodeId I get StatefulRedisConnection via StatefulRedisClusterConnection and use that for subscribing ``` I...

I debugged further and found the source of the issue - In StatefulRedisClusterPubSubConnectionImpl.activated() method - async.clusterMyId() fails in all subsequent reconnections except the first time we create the connection with...

Thanks for the quick reply. Without disabling the stale connections, the disconnects continue indefinitely (it continued for at least 4 days in my own application). IMO this is because nodeId...

@benny1020 We didn't find any solution. So, we ended up disabling the auto-reconnect and handled the re-creation of pub-sub connections from application side.