[
https://issues.apache.org/jira/browse/KAFKA-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13229560#comment-13229560
]
Prashanth Menon commented on KAFKA-304:
---------------------------------------
Hi Neha,
I took a glancing look at the test and I think there might be a mistake. The
line that reads: "assertEquals(message, messageSet.next.message)" should
actually be "assertEquals(message, messageAndOffset.message)". The former
progresses the iterator a second time after the preceeding line so two messages
are consumed within one iteration of the loop, wherare the latter looks at one
message within the current iteration alone. I'll take a closer look when I get
a chance.
> Simple Consumer message set behavior broken on 0.8 branch
> ---------------------------------------------------------
>
> Key: KAFKA-304
> URL: https://issues.apache.org/jira/browse/KAFKA-304
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.8
> Reporter: Neha Narkhede
> Assignee: Prashanth Menon
> Priority: Critical
> Attachments: kafka-240-bug.patch
>
>
> The testZKSendWithDeadBroker() test commented out in ProducerTest actually
> exposes a bug with path KAFKA-240. It seems that even when the broker has
> some messages for a topic partition, the simple consumer doesn't return those.
> I've simplified this test and attached a diff to this bug. Apply it on 0.8
> branch to reproduce this.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
