You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Guozhang Wang (Jira)" <ji...@apache.org> on 2020/01/21 20:00:00 UTC
[jira] [Commented] (KAFKA-9427) StateRestoreListener.onRestoreEnd
should report actual message count
[ 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)