Source file "org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 2,476 of 2,476 | 0% | 191 of 191 | 0% | 147 | 147 | 552 | 552 | 50 | 50 |
| assign(Cluster, ConsumerPartitionAssignor.GroupSubscription) | | 0% | | 0% | 11 | 11 | 70 | 70 | 1 | 1 |
| assignTasksToThreads(Collection, Collection, SortedSet, ClientState) | | 0% | | 0% | 19 | 19 | 65 | 65 | 1 | 1 |
| computeNewAssignment(Set, Map, Map, Map, Map, Set, int, int, boolean, boolean) | | 0% | | 0% | 9 | 9 | 31 | 31 | 1 | 1 |
| onAssignment(ConsumerPartitionAssignor.Assignment, ConsumerGroupMetadata) | | 0% | | 0% | 6 | 6 | 45 | 45 | 1 | 1 |
| assignTasksToClients(Cluster, Set, Map, Map, Map, Set) | | 0% | | 0% | 2 | 2 | 25 | 25 | 1 | 1 |
| populateActiveTaskAndPartitionsLists(List, List, String, ClientState, List, Map, Set) | | 0% | | 0% | 8 | 8 | 25 | 25 | 1 | 1 |
| addClientAssignments(Set, Map, StreamsPartitionAssignor.ClientMetadata, Map, Map, Map, Set, Map, Map, int, int, boolean) | | 0% | | 0% | 4 | 4 | 28 | 28 | 1 | 1 |
| configure(Map) | | 0% | n/a | 1 | 1 | 22 | 22 | 1 | 1 | |
| computeEndOffsetSumsByTask(Map, Map, ChangelogTopics) | | 0% | | 0% | 6 | 6 | 18 | 18 | 1 | 1 |
| populatePartitionsByHostMaps(Map, Map, Map, Map) | | 0% | | 0% | 5 | 5 | 16 | 16 | 1 | 1 |
| populateTasksForMaps(Map, Map, Set, Map, Cluster) | | 0% | | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
| maybeUpdateSubscriptionVersion(int, int) | | 0% | | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
| populateClientStatesMap(Map, Map, Map, ChangelogTopics) | | 0% | | 0% | 2 | 2 | 19 | 19 | 1 | 1 |
| maybeScheduleFollowupRebalance(long, int, int, Set) | | 0% | | 0% | 5 | 5 | 15 | 15 | 1 | 1 |
| buildStandbyTaskMap(String, Iterable, Iterable, Set, Map, ClientState) | | 0% | | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
| checkMetadataVersions(int, int, int) | | 0% | | 0% | 5 | 5 | 17 | 17 | 1 | 1 |
| checkAllPartitions(Set, Map, Set, Cluster) | | 0% | | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
| validateMetadataVersions(int, int) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| errorAssignment(Map, int) | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
| getTopicPartitionInfo(Map) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| validateActiveTaskEncoding(List, AssignmentInfo, String) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| getActiveTasks(List, AssignmentInfo) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| subscriptionUserData(Set) | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| updateMinSupportedVersion(int, int) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| createTaskAssignor(boolean) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| getPreviousTasksByLag(ClientState, String) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| supportedProtocols() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| prepareRepartitionTopics(Cluster) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| verifyHostInfo(Set) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| lambda$assignTasksToClients$3(Map.Entry) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$assignTasksToClients$2(Map.Entry) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| static {...} | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| StreamsPartitionAssignor() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$configure$0(ReferenceContainer) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| handleRebalanceStart(Set) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| updateMinReceivedVersion(int, int) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| setInternalTopicManager(InternalTopicManager) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| acceptableRecoveryLag() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| maxWarmupReplicas() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| numStandbyReplicas() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| probingRebalanceIntervalMs() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$getActiveTasks$6(TaskId) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$populateTasksForMaps$1(TopologyMetadata.Subtopology) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| rebalanceProtocol() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| userEndPoint() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| taskManager() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| uniqueField() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$populateClientStatesMap$5(TaskId) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| name() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$populateClientStatesMap$4(TaskId) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |