diff --git a/offset_manager.go b/offset_manager.go
index 5b8539b58..6c01f959e 100644
--- a/offset_manager.go
+++ b/offset_manager.go
@@ -340,7 +340,7 @@ func (pom *partitionOffsetManager) ResetOffset(offset int64, metadata string) {
 	pom.lock.Lock()
 	defer pom.lock.Unlock()
 
-	if offset < pom.offset {
+	if offset <= pom.offset {
 		pom.offset = offset
 		pom.metadata = metadata
 		pom.dirty = true