change the default value for last_stored_offset (#307)

Gsantomaggio · web-flow · commit e21251f8605c · 2024-05-29T09:32:32.000+02:00
fixes:#306 Signed-off-by: Gabriele Santomaggio <g.santomaggio@gmail.com>
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
`@@ -202,6 +202,7 @@ func (coordinator *Coordinator) NewConsumer(messagesHandler MessagesHandler,`
`202`	`202`	`status: open,`
`203`	`203`	`mutex: &sync.Mutex{},`
`204`	`204`	`MessagesHandler: messagesHandler,`
	`205`	`+ lastStoredOffset: -1, // because 0 is a valid value for the offset`
`205`	`206`	`isPromotedAsActive: true,`
`206`	`207`	`}`
`207`	`208`