change to util.WriteFile

This commit is contained in:
chrislu
2022-02-04 21:32:27 -08:00
parent 76e297d64f
commit affe3c2c12
5 changed files with 7 additions and 6 deletions

View File

@@ -137,7 +137,7 @@ func (progress *KafkaProgress) saveProgress() error {
if err != nil {
return fmt.Errorf("failed to marshal progress: %v", err)
}
err = os.WriteFile(progress.offsetFile, data, 0640)
err = util.WriteFile(progress.offsetFile, data, 0640)
if err != nil {
return fmt.Errorf("failed to save progress to %s: %v", progress.offsetFile, err)
}