Fix: readFromTail when existAckOffset is zero (#624) (#625)

loggie-io · Aug 30, 2023 · 95a00ef · 95a00ef
1 parent 2f3a210
commit 95a00ef
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/pkg/source/file/watch.go b/pkg/source/file/watch.go
@@ -318,10 +318,8 @@ func (w *Watcher) eventBus(e jobEvent) {
 			}
 		}
 		// Pre-allocation offset
-		if existAckOffset == 0 {
-			if e.job.task.config.ReadFromTail {
-				existAckOffset = fileSize
-			}
+		if e.job.task.config.ReadFromTail {
+			existAckOffset = fileSize
 			w.preAllocationOffset(existAckOffset, job)
 		}
 		// set ack offset