[
https://issues.apache.org/jira/browse/STORM-732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554860#comment-14554860
]
Zhuo Liu commented on STORM-732:
--------------------------------
Can we have more description of "messages not exists in kafka"?
Do such messages refer to the ones that are outdated and deleted by kafka?
In which case will such messages still reside in the PartitionManager's
_waitingToEmit queue?
> PartitionManager should remove those messages not exists in kafka from
> waiting queue
> ------------------------------------------------------------------------------------
>
> Key: STORM-732
> URL: https://issues.apache.org/jira/browse/STORM-732
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-kafka
> Affects Versions: 0.10.0
> Reporter: Xin Wang
> Priority: Minor
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
