pub async fn load_cursor( pool: &DbPool, consumer_id: &str, ) -> Result<Option<i64>>
Load the last stored cursor for a consumer. Returns None if no cursor has been stored yet.
None