[ https://issues.apache.org/jira/browse/KAFKA-16930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
David Jacot resolved KAFKA-16930. --------------------------------- Resolution: Fixed > UniformHeterogeneousAssignmentBuilder throws NPE when member has not > subscriptions > ---------------------------------------------------------------------------------- > > Key: KAFKA-16930 > URL: https://issues.apache.org/jira/browse/KAFKA-16930 > Project: Kafka > Issue Type: Sub-task > Affects Versions: 3.7.0 > Reporter: David Jacot > Assignee: David Jacot > Priority: Blocker > Fix For: 3.8.0 > > > {code:java} > java.lang.NullPointerException: Cannot invoke > "org.apache.kafka.coordinator.group.assignor.MemberAssignment.targetPartitions()" > because the return value of "java.util.Map.get(Object)" is null > at > org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.canMemberParticipateInReassignment(GeneralUniformAssignmentBuilder.java:248) > at > org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.balance(GeneralUniformAssignmentBuilder.java:336) > at > org.apache.kafka.coordinator.group.assignor.GeneralUniformAssignmentBuilder.buildAssignment(GeneralUniformAssignmentBuilder.java:157) > at > org.apache.kafka.coordinator.group.assignor.UniformAssignor.assign(UniformAssignor.java:84) > at > org.apache.kafka.coordinator.group.consumer.TargetAssignmentBuilder.build(TargetAssignmentBuilder.java:302) > at > org.apache.kafka.coordinator.group.GroupMetadataManager.updateTargetAssignment(GroupMetadataManager.java:1913) > at > org.apache.kafka.coordinator.group.GroupMetadataManager.consumerGroupHeartbeat(GroupMetadataManager.java:1518) > at > org.apache.kafka.coordinator.group.GroupMetadataManager.consumerGroupHeartbeat(GroupMetadataManager.java:2254) > at > org.apache.kafka.coordinator.group.GroupCoordinatorShard.consumerGroupHeartbeat(GroupCoordinatorShard.java:308) > at > org.apache.kafka.coordinator.group.GroupCoordinatorService.lambda$consumerGroupHeartbeat$0(GroupCoordinatorService.java:298) > at > org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime$CoordinatorWriteEvent.lambda$run$0(CoordinatorRuntime.java:769) > at > org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime.withActiveContextOrThrow(CoordinatorRuntime.java:1582) > at > org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime.access$1400(CoordinatorRuntime.java:96) > at > org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime$CoordinatorWriteEvent.run(CoordinatorRuntime.java:767) > at > org.apache.kafka.coordinator.group.runtime.MultiThreadedEventProcessor$EventProcessorThread.handleEvents(MultiThreadedEventProcessor.java:144) > at > org.apache.kafka.coordinator.group.runtime.MultiThreadedEventProcessor$EventProcessorThread.run(MultiThreadedEventProcessor.java:176) > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)