Previously the implementation would return messageIds that were closest to the current timestamp instead of the messageIds which failed earlier. This means if there was a high rate of sustained failures, the earlier failed messageIds may never have gotten replayed.
Previously the implementation would return messageIds that were closest to the current timestamp instead of the messageIds which failed earlier. This means if there was a high rate of sustained failures, the earlier failed messageIds may never have gotten replayed.