change the default value for last_stored_offset (#307)

fixes:#306 Signed-off-by: Gabriele Santomaggio <[email protected]>
rabbitmq · May 29, 2024 · e21251f · e21251f
1 parent 77deb9d
commit e21251f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/.gitignore b/.gitignore
@@ -28,3 +28,4 @@ dist/
 
 perfTest/perfTest
 go.dev/
+local_ex/
diff --git a/pkg/stream/coordinator.go b/pkg/stream/coordinator.go
@@ -202,6 +202,7 @@ func (coordinator *Coordinator) NewConsumer(messagesHandler MessagesHandler,
 		status:             open,
 		mutex:              &sync.Mutex{},
 		MessagesHandler:    messagesHandler,
+		lastStoredOffset:   -1, // because 0 is a valid value for the offset
 		isPromotedAsActive: true,
 	}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -28,3 +28,4 @@ dist/

		perfTest/perfTest
		go.dev/
		local_ex/