pub async fn wait(self) -> Result<RecordMetadata> {
        let base_offset = self.batch_metadata.base_offset().await?;
        Ok(RecordMetadata {
            partition_id: self.partition_id,
            offset: base_offset + self.relative_offset,
        })
    }
/// wait for the record metadata to be available
wait for the record metadata to be available
wait for the record metadata to be available
pub async fn wait(self) -> Result<RecordMetadata> {
        let base_offset = self.batch_metadata.base_offset().await?;
        Ok(RecordMetadata {
            partition_id: self.partition_id,
            offset: base_offset + self.relative_offset,
        })
    }
pub async fn wait ( self ) -> Result < RecordMetadata > { let base_offset = self . batch_metadata . base_offset ( ) . await ? ; Ok ( RecordMetadata { partition_id : self . partition_id , offset : base_offset + self . relative_offset , } ) }
wait for the record metadata to be available
wait for the record metadata to be available
self
self