diff --git a/.gitignore b/.gitignore index 480d74be..524a7254 100644 --- 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 index d1b8098f..97647763 100644 --- 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, }