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)

Reply via email to