diff --git a/clientlibrary/worker/worker.go b/clientlibrary/worker/worker.go index fb2dd4a..339a7ba 100644 --- a/clientlibrary/worker/worker.go +++ b/clientlibrary/worker/worker.go @@ -292,7 +292,7 @@ func (w *Worker) eventLoop() { if err != nil { // checkpoint may not existed yet is not an error condition. if err != chk.ErrSequenceIDNotFound { - log.Errorf(" Error: %+v", err) + log.Warnf("Couldn't fetch checkpoint: %+v", err) // move on to next shard continue }