Jifeng Yin created STORM-1838:
---------------------------------
Summary: [storm-kafka-client] the resumed OffsetEntry goes
different
Key: STORM-1838
URL: https://issues.apache.org/jira/browse/STORM-1838
Project: Apache Storm
Issue Type: Bug
Reporter: Jifeng Yin
Fix For: 1.0.1
There are no more new messages after consumer rejoins the group. And it turns
out the old OffsetEntry instance kept commitOffsetsForAckedTuples failing.
the comment "leave the acked offsets as they were to resume where it left off"
doesn't work for me, but the ackedMsgs goes different.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)