[
https://issues.apache.org/jira/browse/KAFKA-2056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14495463#comment-14495463
]
Fangmin Lv commented on KAFKA-2056:
-----------------------------------
[~guozhang] I attached a patch, within which the consumers with no partitions
are given Map.empty value. This is done before exiting the assign function.
Instead of this way, we can also initialize partitionAssignments with the
Map.empty for every consumer at the beginning. Which way do you think is more
acceptable?
> 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
> Assignee: Fangmin Lv
> Labels: newbie
> Attachments: KAFKA-2056.patch, KAFKA-2056.patch
>
>
> {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)
