[
https://issues.apache.org/jira/browse/KAFKA-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020529#comment-17020529
]
Guozhang Wang commented on KAFKA-9427:
--------------------------------------
Will do this as part of the KAFKA-9113 cleanup.
> StateRestoreListener.onRestoreEnd should report actual message count
> --------------------------------------------------------------------
>
> Key: KAFKA-9427
> URL: https://issues.apache.org/jira/browse/KAFKA-9427
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Chris Stromberger
> Assignee: Guozhang Wang
> Priority: Minor
>
> {{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]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
