[
https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988003#comment-15988003
]
Jason Gustafson commented on KAFKA-4801:
----------------------------------------
[~original-brownbear] I couldn't reproduce the failure locally either. At a
glance, the test case doesn't look totally safe since we don't actually ensure
that the partition was assigned to the consumer before calling {{position}}. A
simple way to make the test more resilient would be to only execute the
{{commitSync}} block if the call to {{poll}} returned a non-empty record set.
That said, it's unclear in what situation we would lose the partition
assignment, so it would be good to understand that before patching the test
case if possible.
> Transient test failure (part 2):
> ConsumerBounceTest.testConsumptionWithBrokerFailures
> -------------------------------------------------------------------------------------
>
> Key: KAFKA-4801
> URL: https://issues.apache.org/jira/browse/KAFKA-4801
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Armin Braun
> Assignee: Armin Braun
> Priority: Minor
> Labels: transient-system-test-failure
>
> There is still some (but very little ... when reproducing this you need more
> than 100 runs in half the cases statistically) instability left in the test
> {code}
> ConsumerBounceTest.testConsumptionWithBrokerFailures
> {code}
> Resulting in this exception being thrown at a relatively low rate (I'd say
> def less than 0.5% of all runs on my machine).
> {code}
> kafka.api.ConsumerBounceTest > testConsumptionWithBrokerFailures FAILED
> java.lang.IllegalArgumentException: You can only check the position for
> partitions assigned to this consumer.
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1271)
> at
> kafka.api.ConsumerBounceTest.consumeWithBrokerFailures(ConsumerBounceTest.scala:96)
> at
> kafka.api.ConsumerBounceTest.testConsumptionWithBrokerFailures(ConsumerBounceTest.scala:69)
> {code}
> this was also reported in a comment to the original KAFKA-4198
> https://issues.apache.org/jira/browse/KAFKA-4198?focusedCommentId=15765468&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-15765468
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
