pub async fn update_high_watermark(&mut self, offset: Offset) -> Result<(), IoError> {
        let old_offset = self.get_hw();
        if old_offset == offset {
            trace!("new high watermark: {} is same as existing one, skipping",offset);
            Ok(())
        } else {
            trace!("updating to new high watermark: {} old: {}",old_offset,offset);
            self.commit_checkpoint.write(offset).await
        }       
    }
/// update committed offset (high watermark)
update committed offset (high watermark)
update committed offset ( high watermark )
pub async fn update_high_watermark(&mut self, offset: Offset) -> Result<(), IoError> {
        let old_offset = self.get_hw();
        if old_offset == offset {
            trace!("new high watermark: {} is same as existing one, skipping",offset);
            Ok(())
        } else {
            trace!("updating to new high watermark: {} old: {}",old_offset,offset);
            self.commit_checkpoint.write(offset).await
        }       
    }
pub async fn update_high_watermark ( & mut self , offset : Offset ) -> Result < ( ) , IoError > { let old_offset = self . get_hw ( ) ; if old_offset == offset { trace ! ( " " offset ) ; Ok ( ( ) ) } else { trace ! ( " " old_offset offset ) ; self . commit_checkpoint . write ( offset ) . await } }
update committed offset (high watermark)
update committed offset ( high watermark )
&mut self
offset
Offset
&mut self
offset
Offset