pub(crate) async fn get_partition_client( client: &Arc<Client>, topic: &str, ) -> Result<PartitionClient>
Returns a partition client for the given topic.