Source file "org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 3,473 of 3,473 | 0% | 313 of 313 | 0% | 242 | 242 | 657 | 657 | 85 | 85 |
| topicGroups() | | 0% | | 0% | 15 | 15 | 45 | 45 | 1 | 1 |
| addSink(String, TopicNameExtractor, Serializer, Serializer, StreamPartitioner, String[]) | | 0% | | 0% | 7 | 7 | 20 | 20 | 1 | 1 |
| addProcessor(String, ProcessorSupplier, String[]) | | 0% | | 0% | 6 | 6 | 19 | 19 | 1 | 1 |
| InternalTopologyBuilder() | | 0% | n/a | 1 | 1 | 30 | 30 | 1 | 1 | |
| InternalTopologyBuilder(String) | | 0% | n/a | 1 | 1 | 30 | 30 | 1 | 1 | |
| build(Set) | | 0% | | 0% | 7 | 7 | 21 | 21 | 1 | 1 |
| connectProcessorAndStateStore(String, String) | | 0% | | 0% | 6 | 6 | 20 | 20 | 1 | 1 |
| validateGlobalStoreArguments(String, String, String, ProcessorSupplier, String, boolean) | | 0% | | 0% | 7 | 7 | 17 | 17 | 1 | 1 |
| addGlobalStore(StoreBuilder, String, TimestampExtractor, Deserializer, Deserializer, String, String, ProcessorSupplier) | | 0% | n/a | 1 | 1 | 21 | 21 | 1 | 1 | |
| addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, String[]) | | 0% | | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
| addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, Pattern) | | 0% | | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
| addStateStore(StoreBuilder, boolean, String[]) | | 0% | | 0% | 7 | 7 | 13 | 13 | 1 | 1 |
| buildProcessorNode(Map, Map, InternalTopologyBuilder.ProcessorNodeFactory, ProcessorNode) | | 0% | | 0% | 7 | 7 | 16 | 16 | 1 | 1 |
| copartitionGroups() | | 0% | | 0% | 7 | 7 | 22 | 22 | 1 | 1 |
| describeSubtopology(InternalTopologyBuilder.TopologyDescription, Integer, Set) | | 0% | | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
| validateCopartition() | | 0% | | 0% | 6 | 6 | 17 | 17 | 1 | 1 |
| setRegexMatchedTopicToStateStore() | | 0% | | 0% | 8 | 8 | 18 | 18 | 1 | 1 |
| rewriteTopology(StreamsConfig) | | 0% | | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
| connectStateStoreNameToSourceTopicsOrPattern(String, InternalTopologyBuilder.ProcessorNodeFactory) | | 0% | | 0% | 7 | 7 | 19 | 19 | 1 | 1 |
| buildSinkNode(Map, Map, Set, InternalTopologyBuilder.SinkNodeFactory, SinkNode) | | 0% | | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
| validateTopicNotAlreadyRegistered(String) | | 0% | | 0% | 5 | 5 | 7 | 7 | 1 | 1 |
| buildPattern(Collection, Collection) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| addSink(String, String, Serializer, Serializer, StreamPartitioner, String[]) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| describeGlobalStore(InternalTopologyBuilder.TopologyDescription, Set, int) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| findSourcesForProcessorPredecessors(String[]) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| buildSourceNode(Map, Set, InternalTopologyBuilder.SourceNodeFactory, SourceNode) | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
| nodeNames(Set) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| describe() | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| connectProcessorAndStateStores(String, String[]) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| setRegexMatchedTopicsToSourceNodes() | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| globalNodeGroups() | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| addSubscribedTopicsFromAssignment(List, String) | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
| putNodeGroupName(String, int, Map, Map) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| maybeDecorateInternalSourceTopics(Collection) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| initializeSubscription() | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| connectSourceStoreAndTopic(String, String) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| makeNodeGroups() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| buildTopology() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| isGlobalSource(String) | | 0% | | 0% | 5 | 5 | 5 | 5 | 1 | 1 |
| maybeAddToResetList(Collection, Collection, Topology.AutoOffsetReset, Object) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| stateStoreNameToSourceTopics() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| maybeUpdateCopartitionSourceGroups(String, String) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| static {...} | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| createChangelogTopicConfig(InternalTopologyBuilder.StateStoreFactory, String) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| updateSize(InternalTopologyBuilder.AbstractNode, int) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| allStateStoreName() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| decorateTopic(String) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| updateSubscribedTopics(Set, String) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| lambda$validateCopartition$2(Map, String) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| nodeGroupContainsGlobalSourceNode(Set) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| buildGlobalStateTopology() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| addInternalTopic(String, InternalTopicProperties) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| addSubscribedTopicsFromMetadata(Set, String) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
| buildRepartitionTopicConfig(String, Optional) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| buildSubtopology(int) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| hasNoNonGlobalTopology() | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| nodeGroups() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| setApplicationId(String) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| setStreamsConfig(StreamsConfig) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| copartitionSources(Collection) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| globalStateStores() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$copartitionGroups$5(Set) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$null$4(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$buildRepartitionTopicConfig$3(String, Integer) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$validateCopartition$1(Set) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| resetTopicsPattern(Set, Set) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| sourceTopicsForStore(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| usesPatternSubscription() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| hasSubscriptionUpdates() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$null$0(String) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| earliestResetTopicsPattern() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| latestResetTopicsPattern() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| addStateStore(StoreBuilder, String[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| getProcessor(Map, String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| fullSourceTopicNames() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| nodeToSourceTopics() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| decoratePseudoTopic(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| subscriptionUpdates() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getStreamsConfig() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getChangelogTopicToStore() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sourceTopicCollection() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sourceTopicPattern() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sourceTopicNames() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| stateStores() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| hasNamedTopologies() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |