[KAFKA-10101] recovery point is advanced without flushing the data after recovery

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.5.0
• Fix Version/s: 2.8.0
• Component/s: core
• Assignee: Ismael Juma
• Reporter: Jun Rao
• Created: 04/Jun/20 15:47
• Updated: 27/Feb/21 17:59
• Resolved: 26/Feb/21 22:43

Description

Currently, in Log.recoverLog(), we set recoveryPoint to logEndOffset after recovering the log segment. However, we don't flush the log segments after recovery. The potential issue is that if the broker has another hard failure, segments may be corrupted on disk but won't be going through recovery on another restart.

This logic was introduced in KAFKA-5829 since 1.0.0.

Issue Links

• links to: GitHub Pull Request #8812