Allow resetting manager to the same offset

Helpful if you just want to update the metadata, or maybe in more async scenarios.
IBM · Oct 4, 2017 · 96fa1c8 · 96fa1c8
1 parent 1b103ff
commit 96fa1c8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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