Currently, subscriptions to redis streams in the RedisConnector are managed separately for those which should read from the start or not. Actually, this information is superfluous once the stream read ID has been obtained, so the topics can be consolidated and the _get_stream_messages_loop simplified