pub async fn save_cursor( pool: &DbPool, consumer_id: &str, time_us: i64, ) -> Result<()>
Save the cursor position for a consumer.