[
https://issues.apache.org/jira/browse/KAFKA-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14634274#comment-14634274
]
Jason Gustafson commented on KAFKA-2342:
----------------------------------------
[~junrao], I found a case where a rebalance with an in-flight request could
trigger this exception. Basically it was a problem of not validating the
expected offset after a fetch.
I've also reduced the number of broker failures in this test from 20 to 10,
which should help to reduce the test time. This test is pretty good at shaking
out bugs though, so I didn't want to reduce it too much.
> transient unit test failure in testConsumptionWithBrokerFailures
> ----------------------------------------------------------------
>
> Key: KAFKA-2342
> URL: https://issues.apache.org/jira/browse/KAFKA-2342
> Project: Kafka
> Issue Type: Sub-task
> Components: core
> Affects Versions: 0.8.3
> Reporter: Jun Rao
> Assignee: Jason Gustafson
>
> Saw the following transient unit test failure.
> kafka.api.ConsumerBounceTest > testConsumptionWithBrokerFailures FAILED
> java.lang.NullPointerException
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:949)
> at
> kafka.api.ConsumerBounceTest.consumeWithBrokerFailures(ConsumerBounceTest.scala:86)
> at
> kafka.api.ConsumerBounceTest.testConsumptionWithBrokerFailures(ConsumerBounceTest.scala:61)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
