When messages are being sent to the broker and the broker is restarted; periodically the kahadb indexes seem to be corrupted/out of sync

The cursor.queueSize() is reporting messages available on queue but they cannot be consumed.

The orderIndex contains zero messages.

Even after a broker restart the messages reported in the queue cannot be consumed.