[
https://issues.apache.org/jira/browse/KAFKA-2056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14492121#comment-14492121
]
Fangmin Lv commented on KAFKA-2056:
-----------------------------------
The last few consumers may not be assigned with topic partitions if the
partitions are all assigned to the previous consumers. In this case, some
elements in the assignments collection are null which caused the NPE. We can
check the null element before processing in assignAndVerify function.
> PartitionAssignorTest.testRangePartitionAssignor transient failure
> ------------------------------------------------------------------
>
> Key: KAFKA-2056
> URL: https://issues.apache.org/jira/browse/KAFKA-2056
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Guozhang Wang
> Labels: newbie
>
> {code}
> unit.kafka.consumer.PartitionAssignorTest > testRangePartitionAssignor FAILED
> java.lang.NullPointerException
> at
> unit.kafka.consumer.PartitionAssignorTest$$anonfun$unit$kafka$consumer$PartitionAssignorTest$$assignAndVerify$1.apply(PartitionAssignorTest.scala:173)
> at
> unit.kafka.consumer.PartitionAssignorTest$$anonfun$unit$kafka$consumer$PartitionAssignorTest$$assignAndVerify$1.apply(PartitionAssignorTest.scala:172)
> at scala.collection.immutable.List.foreach(List.scala:318)
> at
> unit.kafka.consumer.PartitionAssignorTest$.unit$kafka$consumer$PartitionAssignorTest$$assignAndVerify(PartitionAssignorTest.scala:172)
> at
> unit.kafka.consumer.PartitionAssignorTest$$anonfun$testRangePartitionAssignor$1.apply$mcVI$sp(PartitionAssignorTest.scala:79)
> at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:141)
> at
> unit.kafka.consumer.PartitionAssignorTest.testRangePartitionAssignor(PartitionAssignorTest.scala:60)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
