You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Chris Stromberger (Jira)" <ji...@apache.org> on 2020/01/14 17:03:00 UTC

[jira] [Created] (KAFKA-9427) StateRestoreListener.onRestoreEnd should return actual message count

Chris Stromberger created KAFKA-9427:
----------------------------------------

             Summary: StateRestoreListener.onRestoreEnd should return actual message count
                 Key: KAFKA-9427
                 URL: https://issues.apache.org/jira/browse/KAFKA-9427
             Project: Kafka
          Issue Type: Improvement
            Reporter: Chris Stromberger


{{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)