diff options
Diffstat (limited to 'weed/replication/sub/notification_kafka.go')
| -rw-r--r-- | weed/replication/sub/notification_kafka.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/sub/notification_kafka.go b/weed/replication/sub/notification_kafka.go index 92f7ce609..4f5304cf6 100644 --- a/weed/replication/sub/notification_kafka.go +++ b/weed/replication/sub/notification_kafka.go @@ -135,7 +135,7 @@ func loadProgress(offsetFile string) *KafkaProgress { func (progress *KafkaProgress) saveProgress() error { data, err := json.Marshal(progress) if err != nil { - return fmt.Errorf("failed to marshal progress: %v", err) + return fmt.Errorf("failed to marshal progress: %w", err) } err = util.WriteFile(progress.offsetFile, data, 0640) if err != nil { |