[KAFKA-9427] StateRestoreListener.onRestoreEnd should report actual message count

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Component/s: streams
• Assignee: Guozhang Wang
• Reporter: Chris Stromberger
• Created: 14/Jan/20 17:02
• Updated: 05/Feb/20 17:18
• Resolved: 05/Feb/20 17:18

Description

StateRestoreListener.onRestoreEnd appears to report the difference between offsets as "totalRestored", which may differ from the actual number of messages restored to a state store. Am assuming this is due to missing offsets in compacted topics. It would be more useful if StateRestoreListener.onRestoreEnd reported the actual count of messages restored (sum of values reported by StateRestoreListener.onBatchRestored). 

Was asked to create this ticket in Slack thread https://confluentcommunity.slack.com/archives/C48AHTCUQ/p1578956151094200