Try sharding the pub/sub bus