[
https://issues.apache.org/jira/browse/STORM-2696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangbiao closed STORM-2696.
----------------------------
Resolution: Duplicate
> storm-kafka-client doesn't emit tuple when numUncommittedOffsets -
> readyMessageCount >= maxUncommittedOffsets
> -------------------------------------------------------------------------------------------------------------
>
> Key: STORM-2696
> URL: https://issues.apache.org/jira/browse/STORM-2696
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-kafka-client
> Reporter: zhangbiao
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> for example, when set maxUncommittedOffsets = 10, at first kafka-comsumer
> fetech 500 messges from remote, with 490 messages failed and 10 messgaes
> acked. at this condititon the
> `waitingToEmit` is empty, and `numUncommittedOffsets - readyMessageCount =
> 10 >= maxUncommittedOffsets` , the client will never meet the condition to
> poll again
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
