-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Closed as not planned
Labels
area/clientlifecycle/staletype/bugThe PR fixed a bug or issue reported a bugThe PR fixed a bug or issue reported a bug
Description
Describe the bug
Reader#hasMessageAvailable is used for checking if there is any message available to read from the current position.
But in this case:
Reader#seeka time after the publish time of the last messageReader#hasMessageAvailablestill return true andReader#readNextwill be blocked
It looks unseemly,Reader#hasMessageAvailableshoule gives false since there no more new messages to read.
The reason it thatReader#hasMessageAvailablewill finally callConsumerImpl#getLastMessageIdAsyncwhich just return the last messageId.
Reader#seekhas no effect onReader#hasMessageAvailable.
Related issue [#7775 ]
To Reproduce
Reader#seeka time after the publish time of the last messageReader#hasMessageAvailablestill return true
Expected behavior
Reader#hasMessageAvailable shoule gives false if there no more new messages to read.
Metadata
Metadata
Assignees
Labels
area/clientlifecycle/staletype/bugThe PR fixed a bug or issue reported a bugThe PR fixed a bug or issue reported a bug