fix: reload file need use privious pos (#79)

* fix: reload file need use privious pos * docs: add release notes --------- Co-authored-by: hardy <[email protected]>
infinilabs · Feb 12, 2025 · ff01bf6 · ff01bf6
1 parent 0394683
commit ff01bf6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/docs/content.en/docs/release-notes/_index.md b/docs/content.en/docs/release-notes/_index.md
@@ -15,6 +15,8 @@ Information about release notes of INFINI Framework is provided here.
 
 ### Bug fix
 
+- Fixed reload file need use privious pos (#79)
+
 ### Improvements
 
 ## v1.1.1 (2025-01-24)

diff --git a/modules/queue/disk_queue/consumer.go b/modules/queue/disk_queue/consumer.go
@@ -328,6 +328,7 @@ READ_MSG:
 				log.Debugf("invalid message size detected. this might be due to a partial file load. reloading segment: %d", d.segment)
 			}
 
+			d.readPos = previousPos
 			stats.Increment("consumer", d.qCfg.ID, d.cCfg.ID, "reload_partial_file")
 			goto RELOAD_FILE
 		}