pub(crate) async fn get_offsets_for_topic( partition_client: &PartitionClient, topic: &str, ) -> Result<(u64, u64)>
Returns the earliest and latest offsets for the given topic.