[ https://issues.apache.org/jira/browse/KAFKA-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chris Stromberger updated KAFKA-9427: ------------------------------------- Summary: StateRestoreListener.onRestoreEnd should report actual message count (was: StateRestoreListener.onRestoreEnd should return actual message count) > StateRestoreListener.onRestoreEnd should report actual message count > -------------------------------------------------------------------- > > Key: KAFKA-9427 > URL: https://issues.apache.org/jira/browse/KAFKA-9427 > Project: Kafka > Issue Type: Improvement > Reporter: Chris Stromberger > 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)