cannot use mockClient (variable of type *mocks.Client) as connection.Client value in argument to StartTopicPool: *mocks.Client does not implement connection.Client (missing method PartitionNotReadable)