Source file "org/apache/kafka/clients/consumer/internals/SubscriptionState.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 1,333 of 1,333 | 0% | 151 of 151 | 0% | 161 | 161 | 282 | 282 | 84 | 84 |
| maybeCompleteValidation(TopicPartition, SubscriptionState.FetchPosition, OffsetForLeaderEpochResponseData.EpochEndOffset) | | 0% | | 0% | 9 | 9 | 28 | 28 | 1 | 1 |
| assignFromUser(Set) | | 0% | | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
| prettyString() | | 0% | | 0% | 5 | 5 | 6 | 6 | 1 | 1 |
| assignFromSubscribed(Collection) | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
| toString() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| checkAssignmentMatchedSubscription(Collection) | | 0% | | 0% | 5 | 5 | 10 | 10 | 1 | 1 |
| maybeSeekUnvalidated(TopicPartition, SubscriptionState.FetchPosition, OffsetResetStrategy) | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
| partitionLag(TopicPartition, IsolationLevel) | | 0% | | 0% | 5 | 5 | 6 | 6 | 1 | 1 |
| SubscriptionState(LogContext, OffsetResetStrategy) | | 0% | n/a | 1 | 1 | 10 | 10 | 1 | 1 | |
| maybeValidatePositionForCurrentLeader(ApiVersions, TopicPartition, Metadata.LeaderAndEpoch) | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| metadataTopics() | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| groupSubscribe(Collection) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| unsubscribe() | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| assignedState(TopicPartition) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| subscribeFromPattern(Set) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| requestFailed(Set, long) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| resetInitializingPositions() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| setSubscriptionType(SubscriptionState.SubscriptionType) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| partitionLead(TopicPartition) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| lambda$resetInitializingPositions$6(Set, TopicPartition, SubscriptionState.TopicPartitionState) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| lambda$allConsumed$2(Map, TopicPartition, SubscriptionState.TopicPartitionState) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| setNextAllowedRetry(Set, long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| hasAllFetchPositions() | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| matchesSubscribedPattern(String) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| needsMetadata(String) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| partitionEndOffset(TopicPartition, IsolationLevel) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| isPaused(TopicPartition) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| isFetchable(TopicPartition) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| hasValidPosition(TopicPartition) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| changeSubscription(Set) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| fetchablePartitions(Predicate) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| hasAutoAssignedPartitions() | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| preferredReadReplica(TopicPartition, long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| collectPartitions(Predicate) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$requestOffsetReset$3(OffsetResetStrategy, TopicPartition) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$fetchablePartitions$1(Predicate, List, TopicPartition, SubscriptionState.TopicPartitionState) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
| registerRebalanceListener(ConsumerRebalanceListener) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| allConsumed() | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$partitionsNeedingValidation$8(long, SubscriptionState.TopicPartitionState) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| lambda$partitionsNeedingReset$7(long, SubscriptionState.TopicPartitionState) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| subscribe(Set, ConsumerRebalanceListener) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| subscribe(Pattern, ConsumerRebalanceListener) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| lambda$collectPartitions$5(Predicate, Set, TopicPartition, SubscriptionState.TopicPartitionState) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| hasPatternSubscription() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| hasNoSubscriptionOrUserAssignment() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| subscription() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| seek(TopicPartition, long) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| hasDefaultOffsetResetPolicy() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| assignedPartitions() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| assignedPartitionsList() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| requestPartitionEndOffset(TopicPartition) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| partitionEndOffsetRequested(TopicPartition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| updateHighWatermark(TopicPartition, long) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| updateLogStartOffset(TopicPartition, long) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| updateLastStableOffset(TopicPartition, long) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| updatePreferredReadReplica(TopicPartition, int, LongSupplier) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| assignedStateOrNull(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| seekValidated(TopicPartition, SubscriptionState.FetchPosition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| seekUnvalidated(TopicPartition, SubscriptionState.FetchPosition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| position(TopicPartition, SubscriptionState.FetchPosition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| requestOffsetReset(TopicPartition, OffsetResetStrategy) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| requestOffsetReset(Collection, OffsetResetStrategy) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| requestOffsetReset(TopicPartition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| awaitingValidation(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| completeValidation(TopicPartition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| validPosition(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| position(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| clearPreferredReadReplica(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| isOffsetResetNeeded(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| resetStrategy(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| partitionsNeedingReset(long) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| partitionsNeedingValidation(long) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| isAssigned(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| pause(TopicPartition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| resume(TopicPartition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| movePartitionToEnd(TopicPartition) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$initializingPartitions$4(SubscriptionState.TopicPartitionState) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| resetGroupSubscription() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| pausedPartitions() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| numAssignedPartitions() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| initializingPartitions() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$pausedPartitions$0(Object) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| assignmentId() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| rebalanceListener() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |